Enum TaskEvent 

pub enum TaskEvent {
    Sent {
        task_id: Uuid,
        task_name: String,
        queue: String,
        timestamp: DateTime<Utc>,
        args: Option<String>,
        kwargs: Option<String>,
        eta: Option<DateTime<Utc>>,
        expires: Option<DateTime<Utc>>,
        retries: Option<u32>,
    },
    Received {
        task_id: Uuid,
        task_name: String,
        hostname: String,
        timestamp: DateTime<Utc>,
        pid: u32,
    },
    Started {
        task_id: Uuid,
        task_name: String,
        hostname: String,
        timestamp: DateTime<Utc>,
        pid: u32,
    },
    Succeeded {
        task_id: Uuid,
        task_name: String,
        hostname: String,
        timestamp: DateTime<Utc>,
        runtime: f64,
        result: Option<String>,
    },
    Failed {
        task_id: Uuid,
        task_name: String,
        hostname: String,
        timestamp: DateTime<Utc>,
        exception: String,
        traceback: Option<String>,
    },
    Retried {
        task_id: Uuid,
        task_name: String,
        hostname: String,
        timestamp: DateTime<Utc>,
        exception: String,
        retries: u32,
    },
    Revoked {
        task_id: Uuid,
        task_name: Option<String>,
        timestamp: DateTime<Utc>,
        terminated: bool,
        signum: Option<i32>,
        expired: bool,
    },
    Rejected {
        task_id: Uuid,
        task_name: Option<String>,
        hostname: String,
        timestamp: DateTime<Utc>,
        reason: String,
    },
}

Task lifecycle events (Celery-compatible)

Variants

Sent

Task was sent to the queue

Fields

task_id: Uuid

Unique task ID

task_name: String

Task name (function name)

queue: String

Queue name where task was sent

timestamp: DateTime<Utc>

Event timestamp

args: Option<String>

Task arguments (serialized)

kwargs: Option<String>

Task keyword arguments (serialized)

eta: Option<DateTime<Utc>>

Task ETA if scheduled

expires: Option<DateTime<Utc>>

Task expiration time

retries: Option<u32>

Number of retries configured

Received

Task was received by a worker

Fields

task_id: Uuid

Unique task ID

task_name: String

Task name

hostname: String

Worker hostname

timestamp: DateTime<Utc>

Event timestamp

pid: u32

Worker process ID

Started

Task execution started

Fields

task_id: Uuid

Unique task ID

task_name: String

Task name

hostname: String

Worker hostname

timestamp: DateTime<Utc>

Event timestamp

pid: u32

Worker process ID

Succeeded

Task completed successfully

Fields

task_id: Uuid

Unique task ID

task_name: String

Task name

hostname: String

Worker hostname

timestamp: DateTime<Utc>

Event timestamp

runtime: f64

Execution runtime in seconds

result: Option<String>

Result value (serialized)

Failed

Task execution failed

Fields

task_id: Uuid

Unique task ID

task_name: String

Task name

hostname: String

Worker hostname

timestamp: DateTime<Utc>

Event timestamp

exception: String

Exception type name

traceback: Option<String>

Exception message

Retried

Task is being retried

Fields

task_id: Uuid

Unique task ID

task_name: String

Task name

hostname: String

Worker hostname

timestamp: DateTime<Utc>

Event timestamp

exception: String

Exception that caused retry

retries: u32

Current retry attempt number

Revoked

Task was revoked/cancelled

Fields

task_id: Uuid

Unique task ID

task_name: Option<String>

Task name

timestamp: DateTime<Utc>

Event timestamp

terminated: bool

Whether to terminate running task

signum: Option<i32>

Signal used for termination

expired: bool

Whether task should be expired

Rejected

Task was rejected by worker

Fields

task_id: Uuid

Unique task ID

task_name: Option<String>

Task name

hostname: String

Worker hostname

timestamp: DateTime<Utc>

Event timestamp

reason: String

Rejection reason

Trait Implementations

impl Clone for TaskEvent

fn clone(&self) -> TaskEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TaskEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for TaskEvent

fn eq(&self, other: &TaskEvent) -> 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 TaskEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for TaskEvent