Struct GraphBuilder 

pub struct GraphBuilder { /* private fields */ }

Builder for creating graphs.

The builder owns all graph data until GraphBuilder::build validates it and produces an immutable Graph.

Implementations

impl GraphBuilder

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

pub fn add_task(self, task: Arc<dyn Task>) -> Self

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

pub fn add_conditional_edge<F>( self, from: impl Into<String>, condition: F, yes: impl Into<String>, no: impl Into<String>, ) -> Self

where F: Fn(&Context) -> bool + Send + Sync + 'static,

Add a conditional edge with an explicit else branch. yes is taken when condition(ctx) returns true; otherwise no is chosen.

pub fn set_start_task(self, task_id: impl Into<String>) -> Self

Set the starting task. Validated in GraphBuilder::build; defaults to the first task added.

pub fn with_task_timeout(self, timeout: Duration) -> Self

Set the timeout applied to each task execution (default: 5 minutes).

pub fn with_max_execution_steps(self, max: usize) -> Self

Limit the number of chained ContinueAndExecute steps within a single execute_session call, guarding against infinite loops in cyclic graphs (default: unlimited).

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

Validate the graph and produce an immutable Graph.

Errors

• GraphError::InvalidEdge if an edge references a task that was never added
• GraphError::TaskNotFound if set_start_task names an unknown task