Struct CompiledGraph 

pub struct CompiledGraph<S>
where
    S: Clone + Send + Sync + 'static,
{ /* private fields */ }

Frozen graph ready to execute.

Built by crate::StateGraph::compile; use Runnable::invoke to run.

Implementations

impl<S> CompiledGraph<S>

where S: Clone + Send + Sync + 'static,

pub const fn checkpoint_granularity(&self) -> CheckpointGranularity

Effective checkpoint granularity. Honored by the executor when a Checkpointer is also attached.

pub fn entry_point(&self) -> &str

Borrow the entry-point node name.

pub const fn recursion_limit(&self) -> usize

Effective recursion limit.

pub fn finish_point_count(&self) -> usize

Number of finish points.

pub fn has_checkpointer(&self) -> bool

True when a Checkpointer is bound to this graph.

pub async fn resume(&self, ctx: &ExecutionContext) -> Result<S>

Resume execution from the most recent checkpoint for the (tenant_id, thread_id) pair derived from ctx, continuing as-is. Equivalent to calling Self::resume_with with Command::Resume.

pub async fn resume_with( &self, command: Command<S>, ctx: &ExecutionContext, ) -> Result<S>

Resume execution applying a Command from the most recent checkpoint for the (tenant_id, thread_id) derived from ctx.

Returns Error::Config if the graph has no checkpointer attached or ctx.thread_id() is unset; returns Error::InvalidRequest if the resolved ThreadKey has no recorded checkpoints. If the resolved next-node is None (the saved checkpoint represents a terminated graph), the (possibly updated) state is returned directly without re-running anything.

pub async fn resume_from( &self, checkpoint_id: &CheckpointId, command: Command<S>, ctx: &ExecutionContext, ) -> Result<S>

Time-travel resume: continue execution from a named checkpoint anywhere in history, applying the supplied Command. Combine with Checkpointer::update_state to branch off a historical state.

Trait Implementations

impl<S> Debug for CompiledGraph<S>

where S: Clone + Send + Sync + 'static,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S> Runnable<S, S> for CompiledGraph<S>

where S: Clone + Send + Sync + 'static,

fn invoke<'life0, 'life1, 'async_trait>( &'life0 self, input: S, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<S>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Single-shot invocation.

fn stream<'life0, 'life1, 'async_trait>( &'life0 self, input: S, mode: StreamMode, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'_, Result<StreamChunk<S>>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Streaming invocation, shaped by mode (see StreamMode).

fn batch<'life0, 'life1, 'async_trait>( &'life0 self, inputs: Vec<I>, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<O>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Batch invocation. The default runs invoke sequentially over the input vector. Implementors that can parallelize (e.g. independent provider calls) override this.

fn name(&self) -> Cow<'_, str>

Human-readable identifier used by tracing and debug output. Default is the Rust type name — implementors may override with a domain label (e.g. "anthropic-messages", "json-parser").