Struct WorkflowRunner 

pub struct WorkflowRunner<S: WorkflowStateStore, E: StepExecutor, K: EventSink = NoopEventSink> {
    pub store: S,
    pub executor: E,
    pub events: K,
}

Runs workflows step by step, handling sequential and parallel execution.

Fields

store: S

executor: E

events: K

Implementations

impl<S: WorkflowStateStore, E: StepExecutor> WorkflowRunner<S, E, NoopEventSink>

pub fn new(store: S, executor: E) -> Self

impl<S: WorkflowStateStore, E: StepExecutor, K: EventSink> WorkflowRunner<S, E, K>

pub fn with_events(store: S, executor: E, events: K) -> Self

pub async fn run_next( &self, workflow_id: &str, ) -> Result<Vec<(String, StepResult)>, String>

Run the next runnable step(s). Handles both sequential and parallel. Returns the results of executed steps.

pub async fn run_all(&self, workflow_id: &str) -> Result<WorkflowStatus, String>

Run all steps until completion, failure, blocked, or pause.

pub async fn resume( &self, workflow_id: &str, step_id: &str, input: Value, ) -> Result<WorkflowStatus, String>

Resume a paused workflow by providing input for the waiting step. After providing the input, continues running all remaining steps.

pub async fn get_state( &self, workflow_id: &str, ) -> Result<Option<WorkflowRun>, String>

Get current workflow run state.