Struct WorkflowEngine 

pub struct WorkflowEngine { /* private fields */ }

Workflow execution engine.

Implementations

impl WorkflowEngine

pub fn new(runner: Arc<dyn AgentRunner>, infra: SharedInfra) -> Self

pub fn run<'a>( &'a self, workflow: &'a Workflow, ) -> BoxFuture<'a, Result<WorkflowResult, WorkflowError>>

Execute a workflow to completion, following the stage graph.

pub async fn run_cached( &self, workflow: &Workflow, prior: &WorkflowResult, ) -> Result<WorkflowResult, WorkflowError>

Re-run a workflow, reusing the successful prefix of a prior result.

Every stage that succeeded in prior is replayed from its cached result (instantly, no agent/proposal call); the first stage that did not succeed — and everything after it — runs live, seeded with prior.final_state. Same workflow + same prior result → the same resume point, deterministically.

Use this to recover a long run that failed partway, or to continue after fixing the cause of a failure, without re-paying for completed work. Does not resume an approval pause (use resume for that), though it can newly pause at an approval gate the prior run never reached.

Replayed stages keep their original recorded duration_ms, so summing per-stage durations across the original and cached runs would double-count the replayed prefix.

pub async fn resume( &self, paused: PausedWorkflow, input: HashMap<String, Value>, ) -> Result<WorkflowResult, WorkflowError>

Resume a run that was parked at an approval gate.

Applies input as the approval stage’s response (written to its output_key and mirrored to stage.<id>.answer), records the stage as succeeded, then continues the stage graph. Chained approval gates pause again, returning a fresh PausedWorkflow each time.