Struct ExecutionContext 

pub struct ExecutionContext {
    pub workflow_id: WorkflowId,
    pub variables: Arc<DashMap<String, Value>>,
    pub results: Arc<DashMap<TaskId, TaskResult>>,
}

Execution context shared across task executions.

Fields

workflow_id: WorkflowId

Workflow ID.

variables: Arc<DashMap<String, Value>>

Workflow variables.

results: Arc<DashMap<TaskId, TaskResult>>

Task results cache.

Implementations

impl ExecutionContext

pub fn new(workflow_id: WorkflowId) -> Self

Create a new execution context.

pub fn get_variable(&self, key: &str) -> Option<Value>

Get variable value.

pub fn set_variable(&self, key: String, value: Value)

Set variable value.

pub fn get_result(&self, task_id: &TaskId) -> Option<TaskResult>

Get task result.

pub fn store_result(&self, task_id: TaskId, result: TaskResult)

Store task result.

Trait Implementations

impl Clone for ExecutionContext

fn clone(&self) -> ExecutionContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionContext

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

Formats the value using the given formatter.