Struct TaskLiveness 

pub struct TaskLiveness {
    pub worker_id: WorkerId,
    pub workflow_id: WorkflowId,
    pub activity_id: ActivityId,
    pub attempt: u32,
    pub completion_token: CompletionToken,
    pub heartbeat_window: Duration,
    pub last_heartbeat_at: Instant,
    pub last_progress: Option<Payload>,
    pub last_progress_at: Option<DateTime<Utc>>,
}

Observable liveness state for a single in-flight activity.

Fields

worker_id: WorkerId

Worker currently responsible for the task.

workflow_id: WorkflowId

Owning workflow id.

activity_id: ActivityId

Correlating activity id.

attempt: u32

One-based delivery attempt this tracked dispatch carries (see InFlightActivity::attempt).

completion_token: CompletionToken

Generation authorized to receive a result or synthesized loss.

heartbeat_window: Duration

Operator-configured heartbeat window used for expiry checks.

last_heartbeat_at: Instant

Monotonic timestamp of assignment or the most recent heartbeat.

last_progress: Option<Payload>

Optional worker progress from the most recent heartbeat.

last_progress_at: Option<DateTime<Utc>>

Wall-clock instant this process received the heartbeat that carried Self::last_progress. None while no progress has been reported.

A wall clock rather than the tracked Instant because this one is REPORTED to operators, and a monotonic instant means nothing outside the process that minted it. Server-side observability stamping only — the determinism boundary governs workflow-visible time, and nothing here is workflow-visible.

Trait Implementations

impl Clone for TaskLiveness

fn clone(&self) -> TaskLiveness

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskLiveness

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

Formats the value using the given formatter.

impl Eq for TaskLiveness

impl PartialEq for TaskLiveness

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for TaskLiveness