Struct ScheduledActivity 

pub struct ScheduledActivity {
    pub namespace: String,
    pub task_queue: String,
    pub activity_type: String,
    pub node: Option<String>,
    pub workflow_id: WorkflowId,
    pub activity_id: ActivityId,
    pub run_id: Option<RunId>,
    pub input: Payload,
    pub attempt: u32,
    pub labels: BTreeMap<String, String>,
}

Scheduled remote activity that must be placed with a connected worker.

Fields

namespace: String

Namespace selected by the adapter boundary before dispatch — the correctness/isolation boundary the activity may dispatch within.

task_queue: String

Task queue (pool/flavour) selected within the namespace. The worker-pool address is (namespace, task_queue); an empty value is normalized to the named default pool by the registry lookup.

activity_type: String

Activity type to match against worker registrations, within the selected pool.

node: Option<String>

Optional node locality affinity. Some(node) pins this dispatch to workers advertising that node (require semantics: it waits if none are present, exactly like the no-worker path); None is unpinned and reaches any worker in the (namespace, task_queue) pool — byte-identical to the pre-NODE behaviour. Producers stamp None until SDK selection (NODE-4) and the durable column (NODE-2) land.

workflow_id: WorkflowId

Owning workflow id.

activity_id: ActivityId

Correlating activity id.

run_id: Option<RunId>

Concrete workflow run that staged this task, when known.

input: Payload

Opaque activity input payload.

attempt: u32

One-based delivery attempt stamped by the dispatching engine seam. Zero is malformed on the wire; producers must always stamp it.

labels: BTreeMap<String, String>

Display labels the workflow attached to the activity. Display metadata only — carried to the worker for its logs and the dashboard.

Implementations

impl ScheduledActivity

pub fn to_task(&self) -> ProtoActivityTask

Build the wire task pushed to the worker stream.

Trait Implementations

impl Clone for ScheduledActivity

fn clone(&self) -> ScheduledActivity

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ScheduledActivity

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

Formats the value using the given formatter.

impl Eq for ScheduledActivity

impl PartialEq for ScheduledActivity

fn eq(&self, other: &ScheduledActivity) -> 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 ScheduledActivity