Struct SequentialWorkflow 

pub struct SequentialWorkflow { /* private fields */ }

Sequential workflow: each agent runs in registration order; the former’s output flows into the latter’s input.

Example

use echo_core::agent::{Agent, AgentEvent};
use echo_core::error::Result;
use echo_orchestration::workflow::{SequentialWorkflow, Workflow};
use futures::future::BoxFuture;
use futures::stream::{self, BoxStream};


let agent_a = DummyAgent::new("translator");
let agent_b = DummyAgent::new("reviewer");

let mut wf = SequentialWorkflow::builder()
    .step(agent_a)
    .step(agent_b)
    .build();

let output = wf.run("Hello world").await?;
println!("Final result: {}", output.result);
for s in &output.steps {
    println!("  {} ({:?}): {}", s.agent_name, s.elapsed, &s.output[..s.output.len().min(80)]);
}

Implementations

impl SequentialWorkflow

pub fn builder() -> SequentialWorkflowBuilder

Trait Implementations

impl Workflow for SequentialWorkflow

fn run<'a>( &'a mut self, input: &'a str, ) -> Pin<Box<dyn Future<Output = Result<WorkflowOutput, ReactError>> + Send + 'a>>

Run the entire workflow with input as the initial input

fn run_stream<'a>( &'a mut self, input: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<WorkflowEvent, ReactError>> + Send + 'a>>, ReactError>> + Send + 'a>>

Run the entire workflow with input as initial input (streaming per-node events).