Enum TaskError 

pub enum TaskError {
    Execution(String),
    Timeout(Duration),
    Cancelled,
    DependencyFailed(String),
    InvalidInput(String),
    CircuitOpen(String),
    Other(Error),
}

Errors that can occur while executing an individual task.

Variants

Execution(String)

The task body returned a failure.

Timeout(Duration)

The task exceeded its configured time budget.

Cancelled

The task was cancelled before (or during) execution.

DependencyFailed(String)

An upstream dependency failed, so this task could not run.

InvalidInput(String)

The task received invalid input.

CircuitOpen(String)

The circuit breaker for this task is open.

Other(Error)

Any other error, preserving the source chain.

Implementations

impl TaskError

pub fn execution(msg: impl Display) -> Self

Convenience constructor for an execution failure from any displayable value.

pub fn is_retryable(&self) -> bool

Whether this error is potentially recoverable by retrying.

Trait Implementations

impl Debug for TaskError

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

Formats the value using the given formatter.

impl Display for TaskError

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

Formats the value using the given formatter.

impl Error for TaskError

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 TaskError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<TaskError> for DagExecutorError

fn from(source: TaskError) -> Self

Converts to this type from the input type.