Enum TaskErrorCode 

#[repr(i32)]
pub enum TaskErrorCode {
    Unspecified = 0,
    Timeout = 1,
    InvalidInput = 2,
    ComponentFailed = 3,
    Cancelled = 4,
    Unreachable = 5,
    ComponentNotFound = 6,
    ResourceUnavailable = 7,
    ExpressionFailure = 8,
    OrchestratorError = 9,
    WorkerError = 10,
}

Error codes for task and step failures.

Each variant encodes retryability semantics:

• Always retried (transport): UNREACHABLE, TIMEOUT
• Retried with onError policy: COMPONENT_FAILED, RESOURCE_UNAVAILABLE
• Never retried: all others

Variants

Unspecified = 0

Default value; should not be used explicitly.

Timeout = 1

The task exceeded its execution deadline or heartbeat timeout. Always retried (transport-level).

InvalidInput = 2

The component rejected its input (e.g., missing required fields, schema validation failure). Not retriable without correcting the input.

ComponentFailed = 3

The component executed but returned a business-logic failure (e.g., an API call returned an error, a transformation produced an invalid result). Retriable with onError: retry policy.

Cancelled = 4

The task was explicitly cancelled by the orchestrator (e.g., run cancellation, step timeout policy). Not retriable.

Unreachable = 5

The worker or component could not be reached (e.g., worker disconnected, subprocess crash, network timeout). The component never executed. Always retried (transport-level).

ComponentNotFound = 6

The requested component does not exist on the worker (e.g., unknown component name, misconfigured route). Not retriable without fixing the workflow or routing configuration.

ResourceUnavailable = 7

A resource required by the component was not available during execution (e.g., external API down, database connection failed). Retriable with onError: retry policy.

ExpressionFailure = 8

The orchestrator failed to resolve a value expression (e.g., $step reference to unknown step, path to nonexistent field). Not retriable — the flow definition must be corrected.

OrchestratorError = 9

Catch-all for unexpected orchestrator errors (e.g., internal state corruption, serialization failure). Not retriable.

WorkerError = 10

Catch-all for unexpected worker/SDK errors (e.g., serialization failure, panic, protocol violation). Not retriable.

Implementations

impl TaskErrorCode

pub fn is_valid(value: i32) -> bool

Returns true if value is a variant of TaskErrorCode.

pub fn from_i32(value: i32) -> Option<TaskErrorCode>

👎Deprecated:

Use the TryFrom<i32> implementation instead

Converts an i32 to a TaskErrorCode, or None if value is not a valid variant.

impl TaskErrorCode

pub fn as_str_name(&self) -> &'static str

String value of the enum field names used in the ProtoBuf definition.

The values are not transformed in any way and thus are considered stable (if the ProtoBuf definition does not change) and safe for programmatic use.

pub fn from_str_name(value: &str) -> Option<Self>

Creates an enum from field names used in the ProtoBuf definition.

Trait Implementations

impl Clone for TaskErrorCode

fn clone(&self) -> TaskErrorCode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskErrorCode

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

Formats the value using the given formatter.

impl Default for TaskErrorCode

fn default() -> TaskErrorCode

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for TaskErrorCode

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<TaskErrorCode> for i32

fn from(value: TaskErrorCode) -> i32

Converts to this type from the input type.

impl Hash for TaskErrorCode

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl JsonSchema for TaskErrorCode

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Ord for TaskErrorCode

fn cmp(&self, other: &TaskErrorCode) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl PartialEq for TaskErrorCode

fn eq(&self, other: &TaskErrorCode) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PartialOrd for TaskErrorCode

fn partial_cmp(&self, other: &TaskErrorCode) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl Serialize for TaskErrorCode

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TryFrom<i32> for TaskErrorCode

type Error = UnknownEnumValue

The type returned in the event of a conversion error.

fn try_from(value: i32) -> Result<TaskErrorCode, UnknownEnumValue>

Performs the conversion.

impl Copy for TaskErrorCode

impl Eq for TaskErrorCode

impl StructuralPartialEq for TaskErrorCode