Struct RunStatus 

pub struct RunStatus {
    pub state: RunState,
    pub updated_at: DateTime<Utc>,
    pub heartbeat_at: Option<DateTime<Utc>>,
    pub finished_at: Option<DateTime<Utc>>,
}

Mutable run status — small, atomically rewritten (status.json).

The heartbeat lets a reader distinguish a live run from a crashed one without any protocol: state == Running with a stale heartbeat_at means the process died.

Fields

state: RunState

Current lifecycle state.

updated_at: DateTime<Utc>

When this status file was last rewritten, for any reason.

heartbeat_at: Option<DateTime<Utc>>

Last liveness ping. Stale while state is RunState::Running means the process died.

finished_at: Option<DateTime<Utc>>

When the run reached a terminal state, None while running.

Implementations

impl RunStatus

pub fn running() -> Self

Fresh status for a run that just started: state RunState::Running with the heartbeat stamped now.

Trait Implementations

impl Clone for RunStatus

fn clone(&self) -> RunStatus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunStatus

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RunStatus

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RunStatus

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

where __S: Serializer,

Serialize this value into the given Serde serializer.