Struct Runner 

pub struct Runner<S: Clone + 'static> { /* private fields */ }

Executes a Workflow step by step, handling retries, waits, and routing.

Implementations

impl<S: Clone + 'static> Runner<S>

pub fn new(wf: Workflow<S>) -> Self

Create a runner for the given workflow with default limits (max_steps: 10,000, max_retries: 3).

pub fn with_max_steps(self, max_steps: usize) -> Self

Prevent accidental infinite loops.

pub fn with_max_retries(self, max_retries: usize) -> Self

Set the maximum consecutive retries per agent before failing.

pub fn on_step(self, cb: impl FnMut(&StepEvent<'_>) + 'static) -> Self

Register a callback that fires after each successful agent step.

pub fn on_error(self, cb: impl FnMut(&ErrorEvent<'_>) + 'static) -> Self

Register a callback that fires when an agent errors or a limit is exceeded.

pub fn with_tracing(self) -> Self

Set both hooks to print step transitions and errors to stderr.

pub fn run(&mut self, state: S, ctx: &mut Ctx) -> Result<S, StepError>

Run the workflow to completion, returning the final state or an error. Can be called multiple times on the same runner.