Struct WorkflowBuilder 

pub struct WorkflowBuilder { /* private fields */ }

Builder for constructing workflow DAGs.

Add nodes with node, wire them with edge or conditional, then call build.

Implementations

impl WorkflowBuilder

pub fn new(name: impl Into<String>) -> Self

Create a new workflow builder with the given name.

pub fn node<F, Fut>(self, name: impl Into<String>, handler: F) -> Self

where F: Fn(WorkflowContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Value>> + Send + 'static,

Add a node to the workflow.

The handler receives a WorkflowContext and returns Result<Value>. Nodes with no incoming edges are considered entry points and run first.

pub fn edge(self, from: impl Into<String>, to: impl Into<String>) -> Self

Add a direct edge from one node to another.

The to node will only execute after from completes successfully. Multiple edges into the same node create a join (all predecessors must complete).

pub fn conditional<F>(self, from: impl Into<String>, evaluator: F) -> Self

where F: Fn(&Value) -> Vec<String> + Send + Sync + 'static,

Add a conditional edge from a node.

After from completes, evaluator is called with the node’s result value. It returns a list of downstream node names to activate. Nodes not in the returned list are skipped (treated as completed with a null result).

pub fn build(self) -> Result<Workflow>

Validate and build the workflow.

Returns an error if:

• An edge references a node that does not exist
• The graph contains a cycle
• There are no nodes