Struct Workflow 

pub struct Workflow { /* private fields */ }

A cheaply-clonable (all-Arc) typed orchestration facade.

Every verb delegates to exactly one existing combinator; Workflow owns no scheduling or LLM logic. It is Clone so a phase can itself spawn sub-workflows that share the same event bus, store, and phase numbering.

Implementations

impl Workflow

pub fn builder(executor: Arc<dyn AgentExecutor>) -> WorkflowBuilder

Begin building a workflow around executor.

pub fn root_id(&self) -> &str

The stable root id phase checkpoint keys are derived from.

pub fn budget_snapshot(&self) -> Option<BudgetSnapshot>

A snapshot of the shared budget ledger, if a budget is attached.

pub fn subscribe(&self) -> Receiver<WorkflowEvent>

Subscribe to this workflow’s WorkflowEvent milestones.

pub async fn agent(&self, spec: AgentStepSpec) -> StepOutcome

Run a single step. A one-element barrier — reuses the panic isolation and placement of parallel so one and many steps share a single code path.

pub async fn parallel(&self, specs: Vec<AgentStepSpec>) -> Vec<StepOutcome>

Barrier fan-out. Bounded by the executor’s concurrency_hint; input order is preserved and a panicked branch becomes a failed StepOutcome.

pub async fn phase( &self, name: &str, specs: Vec<AgentStepSpec>, ) -> Vec<StepOutcome>

A named barrier and a resume boundary.

Emits WorkflowEvent::PhaseStart/WorkflowEvent::PhaseEnd around the inner combinator. When a store is configured the phase runs through execute_steps_parallel_resumable keyed by a deterministic "{root_id}/{index}:{name}" id, so an interrupted run skips already completed steps; otherwise it is a plain parallel.

pub async fn pipeline<I>( &self, items: Vec<I>, stages: Vec<PipelineStage<I>>, ) -> Vec<Option<StepOutcome>>

where I: Send + 'static,

Per-item staged chains with no barrier between stages — delegates straight to execute_pipeline. Item A may be in stage 3 while item B is still in stage 1.

pub fn log(&self, level: &str, message: &str, fields: Value)

Emit a best-effort structured log line on the WorkflowEvent stream. Synchronous and non-failing: a full channel drops the line rather than blocking the workflow.

Trait Implementations

impl Clone for Workflow

fn clone(&self) -> Workflow

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.