Enum ActivityCompletionOutcome 

pub enum ActivityCompletionOutcome {
    Succeeded(Payload),
    Failed(ActivityError),
    WorkerLost {
        worker_id: WorkerId,
    },
}

Decoded activity outcome reported by a worker.

Variants

Succeeded(Payload)

Activity completed successfully with an output payload.

Failed(ActivityError)

Activity failed, preserving retryability classification for the engine.

WorkerLost

The worker was lost BEFORE the activity reported any result — a TRANSPORT-domain loss, not an activity failure.

A distinct variant rather than a Failed wearing a retryable kind, because the two are different failure domains and were being conflated: a synthesized retryable:worker ... lost was delivered verbatim as a TERMINAL failure whenever the activity carried no authored retry policy, so every infrastructure death read as a red action. The classification and the transport’s own re-dispatch budget live in transport_loss.

Fields

worker_id: WorkerId

The worker that died holding this activity.

Trait Implementations

impl Clone for ActivityCompletionOutcome

fn clone(&self) -> ActivityCompletionOutcome

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActivityCompletionOutcome

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

Formats the value using the given formatter.

impl Eq for ActivityCompletionOutcome

impl PartialEq for ActivityCompletionOutcome

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ActivityCompletionOutcome