Enum WorkerSessionEvent 

pub enum WorkerSessionEvent {
    Task(ProtoActivityTask),
    Drain,
    ResultAck {
        workflow_id: WorkflowId,
        activity_id: ActivityId,
    },
    Cancel {
        workflow_id: WorkflowId,
        activity_id: ActivityId,
    },
}

Event pushed by the worker session receive stream.

Variants

Task(ProtoActivityTask)

A new activity task to execute.

Drain

Server-initiated drain: the server is going away (restart, deploy, rebalance). The worker finishes in-flight work, reports what it can, stops expecting new tasks, and reconnects after the schedule’s initial backoff. A drain frame latches for the session: the eventual stream end — clean or abrupt — is drain-class and consumes no drop budget.

ResultAck

The server consumed the identified ActivityResult frame; the worker may stop re-reporting it. Clears the matching unacked-tracker entry.

Fields

workflow_id: WorkflowId

Workflow owning the acknowledged result.

activity_id: ActivityId

Activity whose result was acknowledged.

Cancel

Cooperative cancellation for an in-flight activity.

The current AW worker proto in this worktree does not yet carry this frame, but fake sessions can emit it and the runtime handles it without forcing task termination. When AW lands the wire variant, decode_server_message should map it to this event.

Fields

workflow_id: WorkflowId

Workflow owning the activity.

activity_id: ActivityId

Activity to mark cancelled.

Trait Implementations

impl Clone for WorkerSessionEvent

fn clone(&self) -> WorkerSessionEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerSessionEvent

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

Formats the value using the given formatter.

impl Eq for WorkerSessionEvent

impl PartialEq for WorkerSessionEvent

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for WorkerSessionEvent