Struct StateManager 

pub struct StateManager;

Manages workflow execution state

Implementations

impl StateManager

pub fn create_state(workflow: &Workflow) -> WorkflowState

Create a new workflow state

pub fn start_workflow(state: &mut WorkflowState)

Update workflow state to running

pub fn start_step(state: &mut WorkflowState, step_id: String)

Mark a step as started

pub fn complete_step( state: &mut WorkflowState, step_id: String, output: Option<Value>, duration_ms: u64, )

Mark a step as completed

pub fn fail_step( state: &mut WorkflowState, step_id: String, error: String, duration_ms: u64, )

Mark a step as failed

pub fn skip_step(state: &mut WorkflowState, step_id: String)

Mark a step as skipped

pub fn wait_for_approval(state: &mut WorkflowState)

Mark workflow as waiting for approval

pub fn complete_workflow(state: &mut WorkflowState)

Mark workflow as completed

pub fn fail_workflow(state: &mut WorkflowState)

Mark workflow as failed

pub fn cancel_workflow(state: &mut WorkflowState)

Mark workflow as cancelled

pub fn pause_workflow(state: &mut WorkflowState) -> WorkflowResult<()>

Pause workflow execution at current step

pub fn resume_workflow(state: &mut WorkflowState) -> WorkflowResult<()>

Resume workflow execution from paused step

pub fn is_step_completed(state: &WorkflowState, step_id: &str) -> bool

Check if a step has already been completed

pub fn get_next_step_to_execute( state: &WorkflowState, available_steps: &[String], ) -> Option<String>

Get the next step to execute (skipping completed steps)

pub fn persist_state(state: &WorkflowState, path: &Path) -> WorkflowResult<()>

Persist workflow state to file (YAML format)

pub fn persist_state_json( state: &WorkflowState, path: &Path, ) -> WorkflowResult<()>

Persist workflow state to file (JSON format)

pub fn load_state(path: &Path) -> WorkflowResult<WorkflowState>

Load workflow state from file (auto-detects YAML or JSON)

pub fn validate_state(state: &WorkflowState) -> WorkflowResult<()>

Validate state integrity

pub fn load_state_validated(path: &Path) -> WorkflowResult<WorkflowState>

Load state with validation

pub fn load_state_with_recovery(path: &Path) -> WorkflowResult<WorkflowState>

Handle corrupted state file gracefully

pub fn get_progress(state: &WorkflowState, total_steps: usize) -> u32

Get progress percentage (0-100)