Struct WorkflowStepRecord 

pub struct WorkflowStepRecord {
    pub id: Uuid,
    pub workflow_run_id: Uuid,
    pub step_name: String,
    pub status: StepStatus,
    pub result: Option<Value>,
    pub error: Option<String>,
    pub started_at: Option<DateTime<Utc>>,
    pub completed_at: Option<DateTime<Utc>>,
}

A workflow step record in the database.

Fields

id: Uuid

Step record ID.

workflow_run_id: Uuid

Parent workflow run ID.

step_name: String

Step name.

status: StepStatus

Step status.

result: Option<Value>

Step result as JSON.

error: Option<String>

Error message if failed.

started_at: Option<DateTime<Utc>>

When the step started.

completed_at: Option<DateTime<Utc>>

When the step completed.

Implementations

impl WorkflowStepRecord

pub fn new(workflow_run_id: Uuid, step_name: impl Into<String>) -> Self

Create a new step record.

pub fn start(&mut self)

Mark as running.

pub fn complete(&mut self, result: Value)

Mark as completed.

pub fn fail(&mut self, error: impl Into<String>)

Mark as failed.

pub fn compensate(&mut self)

Mark as compensated.

Trait Implementations

impl Clone for WorkflowStepRecord

fn clone(&self) -> WorkflowStepRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowStepRecord

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

Formats the value using the given formatter.