Enum WorkflowError 

pub enum WorkflowError {
    DuplicateTaskId(String),
    TaskNotFound(String),
    TaskNotImplemented(String),
    DefinitionMismatch {
        expected: String,
        found: String,
    },
    Cancelled {
        reason: Option<String>,
        cancelled_by: Option<String>,
    },
    Paused {
        reason: Option<String>,
        paused_by: Option<String>,
    },
    EmptyFork,
    TaskPanicked(String),
    ResumeError(String),
    Deserialization(String),
    BranchNotFound(String),
    Waiting {
        wake_at: DateTime<Utc>,
    },
    TaskTimedOut {
        task_id: String,
        timeout: Duration,
    },
    AwaitingSignal {
        signal_id: String,
        signal_name: String,
        wake_at: Option<DateTime<Utc>>,
    },
    SignalConsumed,
}

Unified error type for workflow operations.

Variants

DuplicateTaskId(String)

A duplicate task ID was found during workflow building.

TaskNotFound(String)

A referenced task ID was not found in the registry.

TaskNotImplemented(String)

The task has no implementation (function body).

DefinitionMismatch

The workflow definition hash doesn’t match. This indicates the serialized state was created with a different workflow definition.

Fields

expected: String

The expected hash (from current workflow).

found: String

The hash found in the serialized state.

Cancelled

The workflow was cancelled.

Fields

reason: Option<String>

Optional reason for the cancellation.

cancelled_by: Option<String>

Optional identifier of who cancelled the workflow.

Paused

The workflow was paused.

Fields

reason: Option<String>

Optional reason for the pause.

paused_by: Option<String>

Optional identifier of who paused the workflow.

EmptyFork

A fork has no branches and no join task.

TaskPanicked(String)

A task panicked during execution.

ResumeError(String)

Cannot resume workflow from saved state.

Deserialization(String)

Deserialization of binary data failed.

BranchNotFound(String)

A named branch was not found in the outputs.

Waiting

The workflow is waiting for a delay to expire.

Fields

wake_at: DateTime<Utc>

When the delay expires.

TaskTimedOut

Task exceeded its configured timeout duration.

This marks the entire workflow as Failed. The task future is actively dropped (cancelled mid-flight) via tokio::select! in all runners.

Fields

task_id: String

The task that timed out.

timeout: Duration

The configured timeout duration.

AwaitingSignal

The workflow is waiting for an external signal.

Fields

signal_id: String

The signal node ID.

signal_name: String

The named signal being waited on.

wake_at: Option<DateTime<Utc>>

Optional timeout deadline.

SignalConsumed

A buffered signal was consumed during park — execution should continue.

This is an internal sentinel used by park_at_signal when a signal is already buffered. The executor should re-enter the loop.

Implementations

impl WorkflowError

pub fn cancelled() -> Self

Create a new Cancelled error with no reason or source.

pub fn paused() -> Self

Create a new Paused error with no reason or source.

Trait Implementations

impl Clone for WorkflowError

fn clone(&self) -> WorkflowError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowError

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

Formats the value using the given formatter.

impl Display for WorkflowError

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

Formats the value using the given formatter.

impl Error for WorkflowError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0: use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.