Struct WorkflowCheckpoint 

pub struct WorkflowCheckpoint {

    pub checkpoint_id: String,
    pub workflow_id: String,
    pub workflow_name: Option<String>,
    pub timestamp_millis: u64,
    pub iteration_count: usize,
    pub messages: Vec<WorkflowMessage>,
    pub executor_states: HashMap<String, Value>,
    pub shared_state: HashMap<String, Value>,
    pub pending_requests: Vec<PendingRequest>,
    pub fanin_state: HashMap<String, HashMap<String, Value>>,
    pub metadata: HashMap<String, Value>,
    pub graph_signature: String,
    pub version: String,
}

A complete snapshot of a workflow’s execution state.

Fields

checkpoint_id: String

Unique id for this checkpoint.

workflow_id: String

Id of the workflow this checkpoint belongs to.

workflow_name: Option<String>

Optional human-readable workflow name.

timestamp_millis: u64

Creation time in milliseconds since the Unix epoch.

iteration_count: usize

The superstep iteration count at snapshot time.

messages: Vec<WorkflowMessage>

In-flight messages awaiting delivery on resume.

executor_states: HashMap<String, Value>

Per-executor serialized state, keyed by executor id.

shared_state: HashMap<String, Value>

The run’s shared state map.

pending_requests: Vec<PendingRequest>

Requests outstanding at snapshot time.

fanin_state: HashMap<String, HashMap<String, Value>>

Partially-satisfied fan-in barriers: target -> (source -> value).

When a fan-in target has received some but not all of its sources’ messages, the already-delivered messages are buffered on the runner (WorkflowRun::fanin) until the barrier fires. If a checkpoint is taken between source deliveries (they can arrive in different supersteps), this buffer must be captured or the barrier can never complete on resume. Empty for legacy checkpoints written before this field existed (serde default), and for checkpoints with no in-flight fan-in.

metadata: HashMap<String, Value>

Additional metadata (e.g. superstep index, checkpoint type).

graph_signature: String

A deterministic signature of the workflow graph (executor ids + edge topology) this checkpoint was produced from, used to detect resuming against an incompatible graph. Empty for legacy checkpoints written before signatures existed (serde default), which resume with a warning rather than a hard error. See runner::compute_graph_signature.

version: String

Checkpoint format version.

Trait Implementations

impl Clone for WorkflowCheckpoint

fn clone(&self) -> WorkflowCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowCheckpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkflowCheckpoint

fn deserialize<__D>( __deserializer: __D, ) -> Result<WorkflowCheckpoint, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WorkflowCheckpoint

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.