Struct WorkflowContext 

pub struct WorkflowContext {
    pub workflow: WorkflowDefinition,
    pub role_registry: RoleRegistry,
    pub progress_writer: Option<ProgressJournalWriter>,
    pub health_watchdog: Option<RunHealthWatchdog>,
    pub inputs: HashMap<String, Value>,
    pub step_outputs: HashMap<String, ParsedOutput>,
}

Workflow execution context

Fields

workflow: WorkflowDefinition

Workflow definition

role_registry: RoleRegistry

Role registry

progress_writer: Option<ProgressJournalWriter>

Progress journal writer

health_watchdog: Option<RunHealthWatchdog>

Health watchdog

inputs: HashMap<String, Value>

Input values

step_outputs: HashMap<String, ParsedOutput>

Step outputs

Implementations

impl WorkflowContext

pub fn new(workflow: WorkflowDefinition, inputs: HashMap<String, Value>) -> Self

Create new workflow context

pub fn with_progress_journal(self, run_id: String, task: String) -> Self

Enable progress journal

pub fn with_health_watchdog(self, config: HealthCheckConfig) -> Self

Enable health monitoring

pub fn get_step_output(&self, step_id: &str) -> Option<&ParsedOutput>

Get step output

pub fn set_step_output(&mut self, step_id: String, output: ParsedOutput)

Set step output

pub fn substitute_variables(&self, template: &str) -> String

Substitute variables in template