Struct InFlightActivity 

pub struct InFlightActivity {
    pub workflow_id: WorkflowId,
    pub activity_id: ActivityId,
    pub attempt: u32,
    pub completion_token: CompletionToken,
}

In-flight activity assigned to a connected worker.

Fields

workflow_id: WorkflowId

Owning workflow id.

activity_id: ActivityId

Correlating activity id.

attempt: u32

One-based delivery attempt this dispatch carries — the third axis of the (workflow, activity, attempt) identity the transcript, the intervention index, and history all key on.

It is NOT part of the tracker’s key: a completion is addressed by the worker, workflow, and activity together, and widening the key would break that addressing. It is carried so a reader asking about a SPECIFIC attempt — the live describe join asking whose progress note this is — can tell a tracked entry for the attempt it asked about from a lingering entry for a superseded one, instead of attributing one attempt’s note to another.

completion_token: CompletionToken

Generation authorized to receive a result or synthesized loss.

Trait Implementations

impl Clone for InFlightActivity

fn clone(&self) -> InFlightActivity

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InFlightActivity

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

Formats the value using the given formatter.

impl Eq for InFlightActivity

impl PartialEq for InFlightActivity

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for InFlightActivity