Enum Error 

pub enum Error {
    MissingHeader(&'static str),
    InvalidStepHeader {
        header: &'static str,
        value: String,
    },
    ReservedHeaderInSubmit(String),
    InvalidRunId {
        run_id: String,
        reason: &'static str,
    },
    InputMismatch(RunId),
    InconsistentRunState(RunId),
    ReservedKvKey(String),
    ConflictingKvEffect(String),
    EffectsSealed,
    Queue(Error),
    Store(Error),
    Serialization(Error),
    Deserialization(Error),
    RunNotFound(RunId),
    MemberNotSubmitted {
        group_id: RunId,
        key: String,
    },
    DuplicateMemberKey(String),
    GroupMismatch(RunId),
    GroupNotFound(RunId),
}

Errors returned by the runtime’s submission and worker paths.

Variants

MissingHeader(&'static str)

A step job is missing the crate::HEADER_RUN_ID header. Permanent: a misconfigured job will not become valid on retry.

InvalidStepHeader

A step job’s crate::HEADER_STEP header is not a valid u32. Permanent: header value won’t change across retries.

Fields

header: &'static str

Header name.

value: String

Offending value.

ReservedHeaderInSubmit(String)

A submission included a user header starting with the reserved workflow.* prefix. The runtime owns that prefix; submitters must use any other key.

InvalidRunId

A run id or group id is empty, longer than crate::MAX_RUN_ID_LEN bytes or contains a character outside [A-Za-z0-9_-]. See crate::RunId.

Fields

run_id: String

The rejected run id.

reason: &'static str

Which rule the run id broke.

InputMismatch(RunId)

A re-submission of run_id carried spec.input bytes that differ from the original submission’s: the run is active, or it is a typed job whose run result record is retained. Reusing a run_id with new input is treated as a programmer error: pick a fresh run_id for a new run.

InconsistentRunState(RunId)

The durable records of a run disagree with one another. The runtime writes and deletes them together, so the error reports a store the runtime did not write.

ReservedKvKey(String)

A caller KV key passed via crate::RunSpec::effects or staged through an crate::EffectsHandle starts with the reserved workflow/ prefix. The runtime owns that prefix. A caller must use another key.

ConflictingKvEffect(String)

A key was staged through an crate::EffectsHandle for both a write and a delete within one step. The combination has no defined order in the settlement transaction and is rejected when the second operation is staged.

EffectsSealed

An effect was staged through an crate::EffectsHandle or crate::TerminalEffects clone after its delivery returned. Effects are collected when the runner or hook returns; an effect staged after that point cannot join the settlement.

Queue(Error)

Underlying error from a Taquba queue operation.

Store(Error)

Reading or writing a blob in object storage failed.

Serialization(Error)

Serializing a value for workflow storage failed.

Deserialization(Error)

Deserializing a stored value, a typed input or a typed output failed.

RunNotFound(RunId)

A wait named a run the runtime has no record of: never submitted, or terminated with no record retained.

MemberNotSubmitted

A group operation waited on a member of the manifest that was not submitted; RunGroup::resume submits it.

Fields

group_id: RunId

The group id.

key: String

The member’s key.

DuplicateMemberKey(String)

Two members of one group have the same key.

GroupMismatch(RunId)

A submission to an existing group supplied a different member set than the group’s manifest.

GroupNotFound(RunId)

A group operation named a group with no manifest.

Implementations

impl Error

pub fn is_permanent(&self) -> bool

True if retrying the operation will not change the outcome; callers should fast-fail (e.g. dead-letter a step, mark a submission as failed) rather than back off and try again.

Self::Queue delegates to taquba::Error::is_permanent.

Trait Implementations

impl Debug for Error

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

Formats the value using the given formatter.

impl Display for Error

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

Formats the value using the given formatter.

impl Error for Error

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 Error

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for Error

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for Error

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for Error

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for JoinError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for StepError

fn from(err: Error) -> Self

Converts to this type from the input type.