Enum ActivityCompletionOutcome 

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

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.

Refused

The worker HANDED THE TASK BACK because it had no free execution slot — a TRANSPORT-domain non-start, like Self::WorkerLost, and for the same reason: the activity never ran.

A distinct variant rather than a WorkerLost wearing a different message, because nothing is lost and nobody died: the worker is connected, healthy, and working, and the operator reading this must not be told a worker went away. What the two share is the ENGINE-facing consequence — re-dispatch, attempt-neutral, nothing recorded against the action’s budget — so both are classified through the transport domain.

The server should not be able to produce this: it knows every worker’s advertised capacity and does not select one that has reached it. It exists because the two accountings CAN drift — a reconnect race, a redelivery joining an outstanding generation — and a drifted count must not become a false failure.

Fields

worker_id: WorkerId

The worker that declined the dispatch.

reason: String

The worker’s own words for why it declined.

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