Struct CompiledGraph 

pub struct CompiledGraph { /* private fields */ }

Available on crate feature graph only.

A compiled graph ready for execution

Implementations

impl CompiledGraph

Convenience methods for CompiledGraph

pub async fn invoke( &self, input: HashMap<String, Value>, config: ExecutionConfig, ) -> Result<HashMap<String, Value>, GraphError>

Execute the graph synchronously

pub fn stream( &self, input: HashMap<String, Value>, config: ExecutionConfig, mode: StreamMode, ) -> impl Stream<Item = Result<StreamEvent, GraphError>>

Execute with streaming

pub async fn get_state( &self, thread_id: &str, ) -> Result<Option<HashMap<String, Value>>, GraphError>

Get current state for a thread

pub async fn update_state( &self, thread_id: &str, updates: impl IntoIterator<Item = (String, Value)>, ) -> Result<(), GraphError>

Update state for a thread (for human-in-the-loop)

impl CompiledGraph

pub fn with_checkpointer<C>(self, checkpointer: C) -> CompiledGraph

where C: Checkpointer + 'static,

Configure checkpointing

pub fn with_checkpointer_arc( self, checkpointer: Arc<dyn Checkpointer>, ) -> CompiledGraph

Configure checkpointing with Arc

pub fn with_interrupt_before(self, nodes: &[&str]) -> CompiledGraph

Configure interrupt before specific nodes

pub fn with_interrupt_after(self, nodes: &[&str]) -> CompiledGraph

Configure interrupt after specific nodes

pub fn with_recursion_limit(self, limit: usize) -> CompiledGraph

Set recursion limit for cycles

pub fn get_entry_nodes(&self) -> Vec<String>

Get entry nodes

pub fn get_next_nodes( &self, executed: &[String], state: &HashMap<String, Value>, ) -> Vec<String>

Get next nodes after executing the given nodes

pub fn leads_to_end( &self, executed: &[String], state: &HashMap<String, Value>, ) -> bool

Check if any of the executed nodes lead to END

pub fn schema(&self) -> &StateSchema

Get the state schema

pub fn checkpointer(&self) -> Option<&Arc<dyn Checkpointer>>

Get the checkpointer if configured