Struct Graph 

pub struct Graph {
    pub id: String,
    /* private fields */
}

A graph of tasks that can be executed.

A Graph is immutable: it is assembled with GraphBuilder and validated by GraphBuilder::build. Because nothing can change after construction, lookups are plain HashMap reads with no locking.

Fields

id: String

Implementations

impl Graph

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

Create an empty graph with the given id.

Useful as a placeholder (e.g. in tests). Real graphs are built with GraphBuilder.

pub async fn execute_session( &self, session: &mut Session, ) -> Result<ExecutionResult>

Execute the graph with session management.

Runs the session’s current task. If the task returns NextAction::ContinueAndExecute, execution proceeds to the next task within the same call, repeating until a task pauses, waits for input, ends, or the configured max_execution_steps limit is hit.

Note: the session is only persisted by the caller (e.g. crate::FlowRunner::run) after this method returns, so context updates made by intermediate ContinueAndExecute steps are not durable until the whole chain finishes.

pub fn find_next_task( &self, current_task_id: &str, context: &Context, ) -> Option<String>

Find the next task based on edges and conditions

pub fn start_task_id(&self) -> Option<&str>

Get the start task ID

pub fn get_task(&self, task_id: &str) -> Option<Arc<dyn Task>>

Get a task by ID