Struct StateSnapshot 

pub struct StateSnapshot<State> {
    pub values: State,
    pub next_nodes: Vec<NodeId>,
    pub tasks: Vec<NodeId>,
    pub config: CheckpointConfig,
    pub metadata: CheckpointMetadata,
    pub parent_config: Option<CheckpointConfig>,
    pub pending_interrupts: Vec<Interrupt>,
}

A point-in-time view of a thread’s checkpointed state, returned by CompiledGraph::get_state and CompiledGraph::get_state_history.

This is the state-inspection / time-travel surface: it bundles the committed channel values at a checkpoint with everything a caller needs to reason about or resume from that point — the next nodes that would run, the config that addresses this snapshot, the config of its parent (for walking the lineage), the checkpoint metadata (source/step/run id), and any pending interrupts.

Fields

values: State

Committed graph state (channel values) at the snapshot’s checkpoint.

next_nodes: Vec<NodeId>

Nodes that would run if execution resumed from this snapshot.

tasks: Vec<NodeId>

Tasks scheduled for the next superstep (mirrors next_nodes).

config: CheckpointConfig

Config that addresses this snapshot’s checkpoint.

metadata: CheckpointMetadata

Lightweight metadata for the snapshot’s checkpoint (source, step, run id).

parent_config: Option<CheckpointConfig>

Config addressing the parent checkpoint, when one exists.

pending_interrupts: Vec<Interrupt>

Interrupts that paused the run at this checkpoint, if any.

Trait Implementations

impl<State: Clone> Clone for StateSnapshot<State>

fn clone(&self) -> StateSnapshot<State>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<State: Debug> Debug for StateSnapshot<State>

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

Formats the value using the given formatter.