Enum WorkflowError 

pub enum WorkflowError {
    WorkflowNotFound(String),
    TaskNotFound(String),
    CycleDetected,
    InvalidConfiguration(String),
    TaskExecutionFailed {
        task_id: String,
        reason: String,
    },
    TaskTimeout(String),
    TaskCancelled(String),
    DependencyFailed(String),
    Database(String),
    Serialization(Error),
    YamlParsing(Error),
    Io(Error),
    FileWatcher(String),
    InvalidTaskType(String),
    MissingParameter(String),
    InvalidParameter {
        param: String,
        value: String,
    },
    ResourceLimitExceeded {
        resource: String,
        limit: String,
    },
    WorkerPool(String),
    Scheduler(String),
    InvalidCronExpression(String),
    FileNotFound(PathBuf),
    InvalidUrl(ParseError),
    Http(String),
    WebSocket(String),
    LockPoisoned,
    ShutdownInProgress,
    AlreadyRunning(String),
    NotRunning(String),
    InvalidStateTransition {
        from: String,
        to: String,
    },
    Generic(String),
}

Errors that can occur during workflow orchestration.

Variants

WorkflowNotFound(String)

Workflow not found.

TaskNotFound(String)

Task not found.

CycleDetected

Cycle detected in workflow DAG.

InvalidConfiguration(String)

Invalid workflow configuration.

TaskExecutionFailed

Task execution failed.

Fields

task_id: String

Task identifier.

reason: String

Failure reason.

TaskTimeout(String)

Task timeout.

TaskCancelled(String)

Task cancelled.

DependencyFailed(String)

Dependency failure.

Database(String)

Database error.

Serialization(Error)

Serialization error.

YamlParsing(Error)

YAML parsing error.

Io(Error)

I/O error.

FileWatcher(String)

File watcher error.

InvalidTaskType(String)

Invalid task type.

MissingParameter(String)

Missing required parameter.

InvalidParameter

Invalid parameter value.

Fields

param: String

Parameter name.

value: String

Invalid value.

ResourceLimitExceeded

Resource limit exceeded.

Fields

resource: String

Resource type.

limit: String

Limit value.

WorkerPool(String)

Worker pool error.

Scheduler(String)

Scheduler error.

InvalidCronExpression(String)

Invalid cron expression.

FileNotFound(PathBuf)

File not found.

InvalidUrl(ParseError)

Invalid URL.

Http(String)

HTTP error.

WebSocket(String)

WebSocket error.

LockPoisoned

Lock poisoned.

ShutdownInProgress

Shutdown in progress.

AlreadyRunning(String)

Already running.

NotRunning(String)

Not running.

InvalidStateTransition

Invalid state transition.

Fields

from: String

Current state.

to: String

Target state.

Generic(String)

Generic error.

Implementations

impl WorkflowError

pub fn generic(msg: impl Into<String>) -> Self

Create a generic error with a message.

pub fn is_recoverable(&self) -> bool

Check if error is recoverable.

pub fn should_retry(&self) -> bool

Check if error should trigger retry.

Trait Implementations

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.

impl From<Error> for WorkflowError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for WorkflowError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for WorkflowError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<ParseError> for WorkflowError

fn from(source: ParseError) -> Self

Converts to this type from the input type.