Struct ExecutionContext 

pub struct ExecutionContext {
    pub execution_id: ExecutionId,
    pub workflow_id: WorkflowId,
    pub started_at: DateTime<Utc>,
    pub completed_at: Option<DateTime<Utc>>,
    pub state: ExecutionState,
    pub node_results: HashMap<NodeId, NodeExecutionResult>,
    pub variables: HashMap<String, Value>,
    pub checkpoint: Option<ExecutionCheckpoint>,
}

Context for workflow execution

Fields

execution_id: ExecutionId

Unique execution identifier

workflow_id: WorkflowId

The workflow being executed

started_at: DateTime<Utc>

When the execution started

completed_at: Option<DateTime<Utc>>

When the execution completed (if finished)

state: ExecutionState

Current execution state

node_results: HashMap<NodeId, NodeExecutionResult>

Node execution results

variables: HashMap<String, Value>

Global variables/context available to all nodes

checkpoint: Option<ExecutionCheckpoint>

Checkpoint data for resume capability

Implementations

impl ExecutionContext

pub fn new(workflow_id: WorkflowId) -> Self

pub fn create_checkpoint(&mut self) -> ExecutionCheckpoint

Create a checkpoint of the current execution state

pub fn resume_from_checkpoint( checkpoint: ExecutionCheckpoint, workflow_id: WorkflowId, ) -> Self

Resume from a checkpoint

pub fn can_resume(&self) -> bool

Check if execution can be resumed

pub fn pause(&mut self)

Pause execution

pub fn resume(&mut self)

Resume paused execution

pub fn cancel(&mut self)

Cancel execution

pub fn mark_completed(&mut self)

Mark execution as completed

pub fn record_node_result( &mut self, node_id: NodeId, result: NodeExecutionResult, )

Record the result of a node execution

pub fn get_node_result(&self, node_id: &NodeId) -> Option<&NodeExecutionResult>

Get the result of a previous node execution

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

Set a variable in the execution context

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

Get a variable from the execution context

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.

impl<'de> Deserialize<'de> for ExecutionContext

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExecutionContext

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.