Struct WorkflowState 

pub struct WorkflowState {
    pub workflow_id: String,
    pub current_step: Option<String>,
    pub completed_steps: Vec<String>,
    pub workflow_data: HashMap<String, Value>,
    pub status: WorkflowStatus,
    pub started_at: Instant,
    pub completed_at: Option<Instant>,
}

Tracks the state of a workflow execution

Fields

workflow_id: String

Unique workflow identifier

current_step: Option<String>

Current active step/agenda group

completed_steps: Vec<String>

List of completed steps

workflow_data: HashMap<String, Value>

Workflow-specific data storage

status: WorkflowStatus

Current status of the workflow

started_at: Instant

Workflow start time

completed_at: Option<Instant>

Workflow completion time

Implementations

impl WorkflowState

pub fn new(workflow_id: String) -> Self

Create a new workflow state

pub fn complete_step(&mut self, step: String)

Mark a step as completed

pub fn set_current_step(&mut self, step: String)

Set the current active step

pub fn complete(&mut self)

Complete the workflow

pub fn fail(&mut self)

Fail the workflow

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

Set workflow data

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

Get workflow data

pub fn duration(&self) -> Duration

Get workflow duration

Trait Implementations

impl Clone for WorkflowState

fn clone(&self) -> WorkflowState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowState

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

Formats the value using the given formatter.