Enum WorkflowCheckpointPhase 

#[non_exhaustive]
pub enum WorkflowCheckpointPhase {
    Ready,
    StepInFlight {
        step: StepId,
    },
    Waiting {
        step: StepId,
        wait: WorkflowWait,
    },
    ParallelInFlight {
        step: StepId,
        branches: BTreeMap<StepId, ParallelBranchCheckpoint>,
    },
    RaceInFlight {
        step: StepId,
        branches: BTreeMap<StepId, ParallelBranchCheckpoint>,
    },
    Completed {
        outcome: WorkflowOutcome,
    },
}

Persisted workflow execution phase.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Ready

Stable output is ready for the next node.

StepInFlight

One node may have partially executed.

Fields

step: StepId

Stable interrupted node identity.

Waiting

The worker lease was released while this node awaits a durable wake.

Fields

step: StepId

Stable waiting node identity.

wait: WorkflowWait

Durable wake condition.

ParallelInFlight

A parallel node has one or more incomplete branches.

Fields

step: StepId

Stable parallel node identity.

branches: BTreeMap<StepId, ParallelBranchCheckpoint>

Durable branch progress keyed independently of completion order.

RaceInFlight

A first-success race has no durable winner yet, or awaits commit.

Fields

step: StepId

Stable race node identity.

branches: BTreeMap<StepId, ParallelBranchCheckpoint>

Durable branch progress keyed independently of completion order.

Completed

The workflow reached a terminal output.

Fields

outcome: WorkflowOutcome

Complete canonical workflow result.

Trait Implementations

impl Clone for WorkflowCheckpointPhase

fn clone(&self) -> WorkflowCheckpointPhase

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowCheckpointPhase

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkflowCheckpointPhase

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for WorkflowCheckpointPhase

fn eq(&self, other: &WorkflowCheckpointPhase) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for WorkflowCheckpointPhase

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for WorkflowCheckpointPhase