Struct WorkflowRecord 

pub struct WorkflowRecord {
    pub id: Uuid,
    pub workflow_name: String,
    pub version: u32,
    pub input: Value,
    pub output: Option<Value>,
    pub status: WorkflowStatus,
    pub current_step: Option<String>,
    pub step_results: Value,
    pub started_at: DateTime<Utc>,
    pub completed_at: Option<DateTime<Utc>>,
    pub error: Option<String>,
    pub trace_id: Option<String>,
}

A workflow run record in the database.

Fields

id: Uuid

Unique workflow run ID.

workflow_name: String

Workflow name.

version: u32

Workflow version.

input: Value

Input data as JSON.

output: Option<Value>

Output data as JSON (if completed).

status: WorkflowStatus

Current status.

current_step: Option<String>

Current step name.

step_results: Value

Step results as JSON map.

started_at: DateTime<Utc>

When the workflow started.

completed_at: Option<DateTime<Utc>>

When the workflow completed.

error: Option<String>

Error message if failed.

trace_id: Option<String>

Trace ID for distributed tracing.

Implementations

impl WorkflowRecord

pub fn new(workflow_name: impl Into<String>, version: u32, input: Value) -> Self

Create a new workflow record.

pub fn with_trace_id(self, trace_id: impl Into<String>) -> Self

Set trace ID.

pub fn start(&mut self)

Mark as running.

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

Mark as completed.

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

Mark as failed.

pub fn compensating(&mut self)

Mark as compensating.

pub fn compensated(&mut self)

Mark as compensated.

pub fn set_current_step(&mut self, step: impl Into<String>)

Update current step.

pub fn add_step_result(&mut self, step_name: &str, result: Value)

Add step result.

Trait Implementations

impl Clone for WorkflowRecord

fn clone(&self) -> WorkflowRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowRecord

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

Formats the value using the given formatter.