Struct CheckpointEntry 

pub struct CheckpointEntry {
    pub run_id: String,
    pub step_id: String,
    pub status: StepStatus,
    pub started_at: Option<u64>,
    pub completed_at: Option<u64>,
    pub duration_ms: Option<u64>,
    pub state_snapshot: Option<String>,
    pub output_log: Option<String>,
    pub error_message: Option<String>,
}

Checkpoint for a single step

Fields

run_id: String

Run this checkpoint belongs to

step_id: String

Step identifier

status: StepStatus

Current status

started_at: Option<u64>

When the step started

completed_at: Option<u64>

When the step completed

duration_ms: Option<u64>

Duration in milliseconds

state_snapshot: Option<String>

State snapshot as JSON

output_log: Option<String>

Output log

error_message: Option<String>

Error message if failed

Implementations

impl StepCheckpoint

pub fn new(run_id: &str, step_id: &str) -> Self

Create a new pending step checkpoint

pub fn start(&mut self)

Mark the step as running

pub fn complete(&mut self, output: Option<String>)

Mark the step as completed

pub fn fail(&mut self, error: &str)

Mark the step as failed

pub fn skip(&mut self)

Mark the step as skipped

Trait Implementations

impl Clone for StepCheckpoint

fn clone(&self) -> StepCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StepCheckpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StepCheckpoint

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StepCheckpoint

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.