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 timeout_policy_for(&self, node_name: &str) -> Option<&TimeoutPolicy>

Get the effective timeout policy for a node.

Returns the per-node policy if one was configured via [GraphAgentBuilder::node_timeout], otherwise falls back to the default timeout policy. Returns None if neither is set.

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 get_upstream_nodes(&self, target_node: &str) -> Vec<String>

Get all upstream source nodes for a given target node.

Returns the names of all nodes that have an edge pointing to the given target node. This is used by the deferred node scheduler to determine which upstream paths must complete before a fan-in node can execute.

For conditional edges, all possible source nodes are included since any of them could route to the target at runtime.

pub fn schema(&self) -> &StateSchema

Get the state schema

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

Get the checkpointer if configured