Skip to main content

CompiledGraph

Struct CompiledGraph 

Source
pub struct CompiledGraph<S: GraphState> { /* private fields */ }
Expand description

A validated, ready-to-run graph. Cheap to clone (the underlying nodes are Arc<dyn Node<S>>).

Implementations§

Source§

impl<S: GraphState> CompiledGraph<S>

Source

pub fn analyze(&self) -> GraphAnalysis

Compute static-graph diagnostics. See GraphAnalysis.

Source§

impl<S: GraphState> CompiledGraph<S>

Source

pub fn with_durability(self, d: Durability) -> Self

Override checkpoint timing relative to step execution. Default is Durability::Sync.

Source

pub fn durability(&self) -> &Durability

Current durability mode.

Source

pub fn node_count(&self) -> usize

Number of registered nodes — useful for testing / introspection.

Source

pub fn node_names(&self) -> Vec<&str>

Names of all registered nodes.

Source

pub fn version(&self) -> Option<&str>

Optional graph version tag (set via crate::builder::Graph::with_version).

Source

pub fn annotations(&self, node_name: &str) -> &HashMap<String, Value>

All annotations attached to node_name, or an empty map if the node has no annotations / isn’t registered.

Source

pub fn annotation(&self, node_name: &str, key: &str) -> Option<&Value>

Look up a single annotation value by (node_name, key).

Source§

impl<S: GraphState + Clone + Send + 'static> CompiledGraph<S>

Source

pub fn with_checkpointer(self, cp: Arc<dyn Checkpointer<S>>) -> Self

Attach a checkpointer; the engine will save state after each superstep.

Source

pub fn with_interrupt_before<I, N>(self, names: I) -> Self
where I: IntoIterator<Item = N>, N: Into<String>,

Pause the graph BEFORE each named node executes. Requires a checkpointer (errors at invoke time if not configured). Interrupt names are validated at invoke time, not compile time, because with_interrupt_before runs after compile(). Resume via CompiledGraph::resume.

Source

pub fn with_interrupt_after<I, N>(self, names: I) -> Self
where I: IntoIterator<Item = N>, N: Into<String>,

Pause the graph AFTER each named node completes (state already updated). Requires a checkpointer. Resume via CompiledGraph::resume.

Source

pub async fn resume( &self, run_id: Uuid, step: u64, state: S, config: RunnableConfig, ) -> Result<S>
where S::Update: Clone,

Continue execution from a previously-interrupted run.

state is the (possibly user-edited) state to seed the next superstep with. run_id and step come from the original GraphInterrupted error. The resume’s RunnableConfig::run_id is set to run_id so observers can correlate with the original run.

Source

pub async fn get_state(&self, run_id: Uuid) -> Result<Option<S>>

Latest checkpointed state for run_id. Returns None if there is no checkpointer attached or no state recorded for that run.

Source

pub async fn get_state_at(&self, run_id: Uuid, step: u64) -> Result<Option<S>>

State at a specific superstep — for time-travel.

Source

pub async fn get_state_history(&self, run_id: Uuid) -> Result<Vec<(u64, S)>>

Full step history for run_id. Each (step, state) pair is one superstep boundary — earliest first.

Source

pub async fn update_state( &self, run_id: Uuid, step: u64, state: &S, ) -> Result<()>

Save a (possibly user-edited) state at step for run_id. Used to patch state before resuming an interrupted run.

Errors if no checkpointer is attached.

Source§

impl<S> CompiledGraph<S>
where S: GraphState + Clone + Send + 'static, <S as GraphState>::Update: Clone,

Source

pub async fn stream_mode( &self, input: S, modes: StreamModes, config: RunnableConfig, ) -> Result<EventStream>

Stream events filtered by StreamModes — see the stream_mode module for what each mode captures.

Source§

impl<S: GraphState> CompiledGraph<S>

Source

pub fn snapshot(&self) -> GraphSnapshot

Snapshot the graph’s static shape.

Source§

impl<S: GraphState> CompiledGraph<S>

Source

pub fn to_ascii(&self) -> String

Render the graph as an ASCII summary suitable for terminal output.

Layout:

Graph (start: <name>)
  nodes:
    - a
    - b
    - c
  edges:
    a -> b
    b -> c
Source§

impl<S: GraphState> CompiledGraph<S>

Source

pub fn to_dot(&self) -> String

Render the graph as a GraphViz digraph source string.

Layout:

  • Every registered node is a rectangle.
  • The configured start node is highlighted with a bold border.
  • A synthetic __END__ node is included as a stadium-shaped sink.
  • Static edges declared via Graph::edge are drawn as arrows.

Dynamic routing (via Goto::Send / Goto::Multiple returned from a node) is not captured — only what the builder declared statically.

Source§

impl<S: GraphState> CompiledGraph<S>

Methods on CompiledGraph<S> that emit a Mermaid flowchart diagram.

Source

pub fn to_mermaid(&self) -> String

Render the graph as a Mermaid flowchart TD source string.

Includes:

  • The configured start node (highlighted with a bold border).
  • Every registered node.
  • Every static edge declared via Graph::edge.
  • A synthetic __END__ sink node — edges drawn from any node that has no outgoing static edge (since dynamic Goto::End cannot be inferred from the static graph).

Trait Implementations§

Source§

impl<S: Clone + GraphState> Clone for CompiledGraph<S>

Source§

fn clone(&self) -> CompiledGraph<S>

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl<S: GraphState> Debug for CompiledGraph<S>

Source§

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

Formats the value using the given formatter. Read more
Source§

impl<S> Runnable<S, S> for CompiledGraph<S>
where S: GraphState + Clone + Send + 'static, <S as GraphState>::Update: Clone,

Source§

fn stream_events<'life0, 'async_trait>( &'life0 self, input: S, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<EventStream>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Override the default stream_events to emit real per-node events as the engine runs (real-time, not synthetic OnEnd-only). Engine events embed serde_json::Value::Null so S: Serialize is not required.

Source§

fn invoke<'life0, 'async_trait>( &'life0 self, input: S, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<S>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

One-shot invocation. The hot path.
Source§

fn name(&self) -> &str

Friendly name for telemetry / introspection.
Source§

fn batch<'life0, 'async_trait>( &'life0 self, inputs: Vec<I>, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Vec<O>, CognisError>> + Send + 'async_trait>>
where 'life0: 'async_trait, I: 'static, O: 'static, Self: Sized + Sync + 'async_trait,

Run multiple inputs in parallel. Defaults to buffer_unordered honouring config.max_concurrency.
Source§

fn stream<'life0, 'async_trait>( &'life0 self, input: I, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<RunnableStream<O>, CognisError>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: Sized + Sync + 'async_trait,

Stream the final output (chunks of O). Default emits one item via invoke — non-streaming runnables are correct without override.
Source§

fn input_schema(&self) -> Option<Value>

JSON Schema for the input type, if known.
Source§

fn output_schema(&self) -> Option<Value>

JSON Schema for the output type, if known.

Auto Trait Implementations§

§

impl<S> Freeze for CompiledGraph<S>

§

impl<S> !RefUnwindSafe for CompiledGraph<S>

§

impl<S> Send for CompiledGraph<S>

§

impl<S> Sync for CompiledGraph<S>

§

impl<S> Unpin for CompiledGraph<S>

§

impl<S> UnsafeUnpin for CompiledGraph<S>

§

impl<S> !UnwindSafe for CompiledGraph<S>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DynClone for T
where T: Clone,

Source§

fn __clone_box(&self, _: Private) -> *mut ()

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<R, I, O> RunnableExt<I, O> for R
where R: Runnable<I, O>, I: Send + 'static, O: Send + 'static,

Source§

fn pipe<R2, O2>(self, next: R2) -> Pipe<Self, R2, I, O, O2>
where R2: Runnable<O, O2>, O2: Send + 'static,

Pipe this runnable into another, building a Pipe<Self, Next>.
Source§

fn with_retry(self, policy: RetryPolicy) -> Retry<Self, I, O>
where I: Clone,

Wrap with a retry policy.
Source§

fn with_max_retries(self, attempts: u32) -> Retry<Self, I, O>
where I: Clone,

Shortcut: retry with default policy and N attempts.
Source§

fn with_timeout(self, duration: Duration) -> Timeout<Self, I, O>

Wrap with a per-call timeout.
Source§

fn with_fallback<F>(self, fallback: F) -> Fallback<Self, F, I, O>
where F: Runnable<I, O>, I: Clone,

Wrap with a fallback runnable.
Source§

fn with_memory_cache<K, F>( self, key_fn: F, ) -> Cache<Self, I, O, K, MemoryCache<K, O>>
where K: Hash + Eq + Clone + Send + Sync + 'static, O: Clone + Send + Sync + 'static, F: Fn(&I) -> K + Send + Sync + 'static,

Wrap with an in-memory cache keyed by key_fn(&I).
Source§

fn each(self) -> Each<Self, I, O>

Apply this runnable to each element of a Vec<I> (preserves order).
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more