Struct Checkpoint 

pub struct Checkpoint {
    pub thread_id: String,
    pub checkpoint_id: String,
    pub state: HashMap<String, Value>,
    pub step: usize,
    pub pending_nodes: Vec<String>,
    pub metadata: HashMap<String, Value>,
    pub created_at: DateTime<Utc>,
    pub cleared_interrupt: Option<String>,
    pub attempts: HashMap<String, u32>,
    pub child_ledger: HashMap<String, Value>,
}

Available on crate feature graph only.

Checkpoint data structure for persistence

Fields

thread_id: String

Thread identifier

checkpoint_id: String

Unique checkpoint ID

state: HashMap<String, Value>

State at this checkpoint

step: usize

Step number

pending_nodes: Vec<String>

Nodes pending execution

metadata: HashMap<String, Value>

Additional metadata

created_at: DateTime<Utc>

Creation timestamp

cleared_interrupt: Option<String>

The node whose static interrupt produced this checkpoint.

A static interrupt is raised before the node runs, so the checkpoint holds a frontier that still contains it. Without this marker the resumed run reaches the same conclusion and raises the same interrupt, and the node never executes. The executor clears the marker once that node has run, so a cycle returning to the same gate asks again.

attempts: HashMap<String, u32>

How many times each node has been attempted, for retry policies.

Held here so a retry budget survives a resume. adk-python does not persist its attempt count, so a resumed node there starts its budget again.

child_ledger: HashMap<String, Value>

Outputs of children invoked imperatively from a node body, keyed by child path.

A resumed parent re-runs from the top, so without this every child would run again. Only successful outputs are recorded: a failed or interrupted child must re-run.

Implementations

impl Checkpoint

pub fn new( thread_id: &str, state: HashMap<String, Value>, step: usize, pending_nodes: Vec<String>, ) -> Checkpoint

Create a new checkpoint

pub fn with_cleared_interrupt(self, node: impl Into<String>) -> Checkpoint

Record the node whose static interrupt produced this checkpoint.

pub fn with_metadata(self, key: &str, value: Value) -> Checkpoint

Add metadata to the checkpoint

Trait Implementations

impl Clone for Checkpoint

fn clone(&self) -> Checkpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Checkpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Checkpoint

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Checkpoint

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.