Enum TaskStatus 

pub enum TaskStatus {
    Pending,
    InProgress {
        worker_id: String,
    },
    Completed {
        output: Value,
    },
    Failed {
        error: String,
        attempt: u32,
    },
    DeadLetter {
        error: String,
    },
}

Lifecycle status of a WorkTask.

Example

use stygian_graph::ports::work_queue::TaskStatus;

let status = TaskStatus::Pending;
assert!(matches!(status, TaskStatus::Pending));

Variants

Pending

Task is queued, not yet claimed by a worker

InProgress

A worker has claimed the task and is executing it

Fields

worker_id: String

Identifier of the worker processing this task

Completed

Task completed successfully

Fields

output: Value

Output produced by the service (serialised as JSON)

Failed

Task failed; will be retried if attempt < max_attempts

Fields

error: String

Human-readable error message

attempt: u32

Which attempt number failed

DeadLetter

Task has exhausted all retries and moved to the dead-letter queue

Fields

error: String

Final error message

Trait Implementations

impl Clone for TaskStatus

fn clone(&self) -> TaskStatus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskStatus

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TaskStatus

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TaskStatus

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

where __S: Serializer,

Serialize this value into the given Serde serializer.