Struct ActivityContext 

pub struct ActivityContext { /* private fields */ }

User-facing orchestration context for scheduling and replay-safe helpers. Context provided to activities for logging and metadata access.

Unlike OrchestrationContext, activities are leaf nodes that cannot schedule new work, but they often need to emit structured logs and inspect orchestration metadata. The ActivityContext exposes the parent orchestration information and trace helpers that log with full correlation fields.

Examples

let activities = ActivityRegistry::builder()
    .register("ProvisionVM", |ctx: ActivityContext, config: String| async move {
        ctx.trace_info(format!("Provisioning VM with config: {}", config));
         
        // Do actual work (can use sleep, HTTP, etc.)
        let vm_id = provision_vm_internal(config).await?;
         
        ctx.trace_info(format!("VM provisioned: {}", vm_id));
        Ok(vm_id)
    })
    .build();

Metadata Access

Activity context provides access to orchestration correlation metadata:

• instance_id() - Orchestration instance identifier
• execution_id() - Execution number (for ContinueAsNew scenarios)
• orchestration_name() - Parent orchestration name
• orchestration_version() - Parent orchestration version
• activity_name() - Current activity name

Determinism

Activity trace helpers (trace_info, trace_warn, etc.) do not participate in deterministic replay. They emit logs directly using tracing and should only be used for diagnostic purposes.

Implementations

impl ActivityContext

pub fn instance_id(&self) -> &str

Returns the orchestration instance identifier.

pub fn execution_id(&self) -> u64

Returns the execution id within the orchestration instance.

pub fn orchestration_name(&self) -> &str

Returns the parent orchestration name.

pub fn orchestration_version(&self) -> &str

Returns the parent orchestration version.

pub fn activity_name(&self) -> &str

Returns the activity name being executed.

pub fn worker_id(&self) -> &str

Returns the worker dispatcher ID processing this activity.

pub fn trace_info(&self, message: impl Into<String>)

Emit an INFO level trace entry associated with this activity.

pub fn trace_warn(&self, message: impl Into<String>)

Emit a WARN level trace entry associated with this activity.

pub fn trace_error(&self, message: impl Into<String>)

Emit an ERROR level trace entry associated with this activity.

pub fn trace_debug(&self, message: impl Into<String>)

Emit a DEBUG level trace entry associated with this activity.

Trait Implementations

impl Clone for ActivityContext

fn clone(&self) -> ActivityContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActivityContext

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

Formats the value using the given formatter.