Enum TaskErrorCode 

pub enum TaskErrorCode {
    Unspecified,
    Timeout,
    InvalidInput,
    ComponentFailed,
    Cancelled,
    Unreachable,
    ComponentNotFound,
    ResourceUnavailable,
    ExpressionFailure,
    OrchestratorError,
    WorkerError,
}

Categorizes the type of error that occurred during task execution.

Each variant maps to a specific retry policy:

• Always retried (transport): Unreachable, Timeout
• Retried with onError policy: ComponentFailed, ResourceUnavailable
• Never retried: all others

Variants

Unspecified

Default value; should not be used explicitly.

Timeout

The task exceeded its execution deadline or heartbeat timeout.

InvalidInput

The component rejected its input.

ComponentFailed

The component executed but returned a business-logic failure.

Cancelled

The task was explicitly cancelled by the orchestrator.

Unreachable

The worker or component could not be reached.

ComponentNotFound

The requested component does not exist on the worker.

ResourceUnavailable

A resource required by the component was not available.

ExpressionFailure

The orchestrator failed to resolve a value expression.

OrchestratorError

Catch-all for unexpected orchestrator errors.

WorkerError

Catch-all for unexpected worker/SDK errors.

Implementations

impl TaskErrorCode

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

Returns the proto-style name (e.g. "TASK_ERROR_CODE_TIMEOUT").

pub fn proto_number(&self) -> i32

Returns the numeric proto value.

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<'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 Display for TaskErrorCode

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

Formats the value using the given formatter.

impl From<TaskErrorCode> for i32

fn from(code: 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 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 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 = i32

The type returned in the event of a conversion error.

fn try_from(value: i32) -> Result<Self, Self::Error>

Performs the conversion.

impl Copy for TaskErrorCode

impl Eq for TaskErrorCode

impl StructuralPartialEq for TaskErrorCode