Enum Step 

pub enum Step {
    Invoke {
        callable: CallableHandle,
        mapping: InputMapping,
    },
    Branch {
        predicate: Arc<dyn BranchPredicate>,
        if_true: StepId,
        if_false: StepId,
    },
    Parallel {
        steps: Vec<StepId>,
        join: JoinStrategy,
    },
    Loop {
        body: StepId,
        predicate: Arc<dyn BranchPredicate>,
    },
    Map {
        body: StepId,
        concurrency: Concurrency,
    },
    Human {
        approval: HumanApproval,
    },
}

One step in a workflow’s DAG.

Variants

Invoke

Invoke a Callable (tool, agent, or other workflow).

Fields

callable: CallableHandle

mapping: InputMapping

Branch

Branch to one of two next steps based on predicate(output).

Fields

predicate: Arc<dyn BranchPredicate>

if_true: StepId

if_false: StepId

Parallel

Run several steps in parallel; aggregate via JoinStrategy.

Fields

steps: Vec<StepId>

join: JoinStrategy

Loop

Loop a step while the predicate evaluates true.

Fields

body: StepId

predicate: Arc<dyn BranchPredicate>

Map

Apply body once per element of an input array, with bounded concurrency.

Fields

body: StepId

concurrency: Concurrency

Human

Pause the workflow until a human approves. Persists the pending approval so a process restart resumes correctly.

Fields

approval: HumanApproval

Implementations

impl Step

pub fn invoke(callable: CallableHandle) -> Self