streamweave-attractor 0.3.0

Attractor pipeline as a StreamWeave graph
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

//! Run a simple Attractor pipeline via the compiled graph.

use streamweave_attractor::{RunOptions, dot_parser, run_compiled_graph};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
  let dot = r#"
    digraph Simple {
      graph [goal="Run tests and report"]
      rankdir=LR

      start [shape=Mdiamond, label="Start"]
      exit [shape=Msquare, label="Exit"]
      run_tests [label="Run Tests", prompt="Run the test suite"]
      report [label="Report", prompt="Summarize results"]

      start -> run_tests -> report -> exit
    }
  "#;

  let ast = dot_parser::parse_dot(dot)?;
  let r = run_compiled_graph(
    &ast,
    RunOptions {
      run_dir: None,
      resume_state: None,
      resume_already_completed: false,
      agent_cmd: None,
      stage_dir: None,
      execution_log_path: None,
    },
  )
  .await?;

  println!("Pipeline completed.");
  println!("  Status: {:?}", r.last_outcome.status);
  println!("  Notes: {:?}", r.last_outcome.notes);
  println!("  Completed nodes: {:?}", r.completed_nodes);
  Ok(())
}