Enum WorkflowStepDef 

pub enum WorkflowStepDef {
    Run {
        agent: String,
        task: String,
        output: Option<String>,
    },
    Parallel {
        agents: Vec<String>,
        task: String,
        concurrency: Option<usize>,
    },
    Chain {
        steps: Vec<WorkflowStepDef>,
    },
    ForEach {
        items_key: String,
        namespace: Option<String>,
        agent: String,
        task_template: String,
        concurrency: Option<usize>,
    },
    Vote {
        agents: Vec<String>,
        question: String,
        threshold: Option<f32>,
    },
    SetState {
        key: String,
        namespace: Option<String>,
        value: Value,
    },
}

A single step in a workflow.

Variants

Run

Run a single agent with a task.

Fields

agent: String

Name of the agent to run.

task: String

Task prompt to send to the agent.

output: Option<String>

Optional SharedMemory key to store the agent’s result under.

Parallel

Run multiple agents in parallel with the same task.

Fields

agents: Vec<String>

Names of the agents to run concurrently.

task: String

Task prompt sent to every agent.

concurrency: Option<usize>

Maximum number of agents to run at once (defaults to all).

Chain

Run agents sequentially, passing results forward.

Fields

steps: Vec<WorkflowStepDef>

Ordered sub-steps executed one after another.

ForEach

Fan-out: run an agent for each item in a SharedMemory key.

Fields

items_key: String

SharedMemory key holding the list of items to iterate over.

namespace: Option<String>

Optional SharedMemory namespace to read the items from.

agent: String

Name of the agent to run for each item.

task_template: String

Task template with {item} replaced by each item’s value.

concurrency: Option<usize>

Maximum number of agents to run at once (defaults to all).

Vote

Vote: ask multiple agents and aggregate by threshold.

Fields

agents: Vec<String>

Names of the agents whose responses form the vote.

question: String

Question posed to each agent.

threshold: Option<f32>

Fraction of matching responses required to reach consensus (0.0–1.0).

SetState

Set a value in SharedMemory.

Fields

key: String

SharedMemory key to write.

namespace: Option<String>

Optional SharedMemory namespace to write into.

value: Value

JSON value to store at the key.

Trait Implementations

impl Clone for WorkflowStepDef

fn clone(&self) -> WorkflowStepDef

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowStepDef

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkflowStepDef

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WorkflowStepDef

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.