Struct PhaseCheckpoint 

pub struct PhaseCheckpoint {
    pub id: String,
    pub run_id: String,
    pub topology_name: String,
    pub phase_name: String,
    pub sender_id: String,
    pub project: String,
    pub status: String,
    pub output: Option<String>,
    pub error_message: Option<String>,
    pub attempt: i64,
    pub created_at: String,
    pub updated_at: String,
}

A recorded snapshot of one pipeline phase within a run.

Fields

id: String

Unique row identifier.

run_id: String

UUID identifying the enclosing pipeline run.

topology_name: String

Name of the topology (e.g. "my-pipeline").

phase_name: String

Name of the phase within the topology.

sender_id: String

Agent / sender identifier that owns this run.

project: String

Project scope. Empty string = no project.

status: String

One of "pending", "in_progress", "completed", "failed".

output: Option<String>

Phase output text. None until the phase completes successfully.

error_message: Option<String>

Error detail. Set only when status is "failed".

attempt: i64

How many attempts have been made for this phase (0-indexed).

created_at: String

ISO-8601 creation timestamp.

updated_at: String

ISO-8601 last-update timestamp.

Trait Implementations

impl Clone for PhaseCheckpoint

fn clone(&self) -> PhaseCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PhaseCheckpoint

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

Formats the value using the given formatter.