Struct CompiledGraph 

pub struct CompiledGraph { /* private fields */ }

A compiled graph ready for execution

Implementations

impl CompiledGraph

Convenience methods for CompiledGraph

pub async fn invoke( &self, input: State, config: ExecutionConfig, ) -> Result<State>

Execute the graph synchronously

pub fn stream( &self, input: State, config: ExecutionConfig, mode: StreamMode, ) -> impl Stream<Item = Result<StreamEvent>> + '_

Execute with streaming

pub async fn get_state(&self, thread_id: &str) -> Result<Option<State>>

Get current state for a thread

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

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

impl CompiledGraph

pub fn with_checkpointer<C: Checkpointer + 'static>( self, checkpointer: C, ) -> Self

Configure checkpointing

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

Configure checkpointing with Arc

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

Configure interrupt before specific nodes

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

Configure interrupt after specific nodes

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

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: &State) -> Vec<String>

Get next nodes after executing the given nodes

pub fn leads_to_end(&self, executed: &[String], state: &State) -> 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