Struct StepExecutionContext 

pub struct StepExecutionContext<'a> {
    pub item: Option<&'a Value>,
    pub execution_pointer: &'a ExecutionPointer,
    pub persistence_data: Option<&'a Value>,
    pub step: &'a WorkflowStep,
    pub workflow: &'a WorkflowInstance,
    pub definition: Option<&'a WorkflowDefinition>,
    pub cancellation_token: CancellationToken,
    pub host_context: Option<&'a dyn HostContext>,
    pub log_sink: Option<&'a dyn LogSink>,
}

Context available to a step during execution.

Fields

item: Option<&'a Value>

The current item when iterating (ForEach).

execution_pointer: &'a ExecutionPointer

The current execution pointer.

persistence_data: Option<&'a Value>

Persistence data from a previous execution of this step.

step: &'a WorkflowStep

The step definition.

workflow: &'a WorkflowInstance

The running workflow instance.

definition: Option<&'a WorkflowDefinition>

The compiled workflow definition the instance was created from. None on code paths that don’t have it available (some test fixtures); production execution always populates this so executor-specific features (e.g. Kubernetes shared volumes) can inspect the definition-level configuration.

cancellation_token: CancellationToken

Cancellation token.

host_context: Option<&'a dyn HostContext>

Host context for starting child workflows. None if not available.

log_sink: Option<&'a dyn LogSink>

Log sink for streaming step output. None if not configured.

Trait Implementations

impl<'a> Debug for StepExecutionContext<'a>

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

Formats the value using the given formatter.