Struct Graph 

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

A graph of tasks that can be executed

Fields

id: String

Implementations

impl Graph

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

pub fn set_task_timeout(&mut self, timeout: Duration)

Set the timeout duration for task execution

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

Add a task to the graph

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

Set the starting task

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

Add an edge between tasks

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 async fn execute_session( &self, session: &mut Session, ) -> Result<ExecutionResult>

Execute the graph with session management This method manages the session state and returns a simple status

pub async fn execute( &self, task_id: &str, context: Context, ) -> Result<TaskResult>

Execute the graph starting from a specific task

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<String>

Get the start task ID

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

Get a task by ID