Struct TaskRow 

pub struct TaskRow {

    pub job: Vec<u8>,
    pub id: String,
    pub job_type: String,
    pub status: String,
    pub attempts: usize,
    pub max_attempts: Option<usize>,
    pub run_at: Option<DateTime<Utc>>,
    pub last_result: Option<Value>,
    pub lock_at: Option<DateTime<Utc>>,
    pub lock_by: Option<String>,
    pub done_at: Option<DateTime<Utc>>,
    pub priority: Option<usize>,
    pub metadata: Option<Value>,
    pub idempotency_key: Option<String>,
}

Represents a row from the tasks table in the database.

This struct contains all the fields necessary to represent a task/job stored in the SQL database, including its execution state, metadata, and scheduling information.

Fields

job: Vec<u8>

The serialized job data as bytes

id: String

Unique identifier for the task

job_type: String

The type/name of the job being executed

status: String

Current status of the task (e.g., “pending”, “running”, “completed”, “failed”)

attempts: usize

Number of times this task has been attempted

max_attempts: Option<usize>

Maximum number of attempts allowed for this task before giving up

run_at: Option<DateTime<Utc>>

When the task should be executed (for scheduled tasks)

last_result: Option<Value>

The result of the last execution attempt, stored as JSON

lock_at: Option<DateTime<Utc>>

Timestamp when the task was locked for execution

lock_by: Option<String>

Identifier of the worker/process that has locked this task

done_at: Option<DateTime<Utc>>

Timestamp when the task was completed

priority: Option<usize>

Priority level of the task (higher values indicate higher priority)

metadata: Option<Value>

Additional metadata associated with the task, stored as JSON

idempotency_key: Option<String>

Idempotency key for enforcing uniqueness

Implementations

impl TaskRow

pub fn try_into_task<D, Args, IdType, Pool>( self, ) -> Result<Task<Args, SqlContext<Pool>, IdType>, FromRowError>

where <D as Codec<Args>>::Error: Into<Box<dyn Error + Send + Sync>> + Send + Sync + 'static, IdType: FromStr, <IdType as FromStr>::Err: Error + Send + Sync + 'static, D: Codec<Args, Compact = Vec<u8>>, Args: 'static,

Convert the TaskRow into a Task with decoded arguments

pub fn try_into_task_compact<IdType, Pool>( self, ) -> Result<Task<Vec<u8>, SqlContext<Pool>, IdType>, FromRowError>

where IdType: FromStr, <IdType as FromStr>::Err: Error + Send + Sync + 'static,

Convert the TaskRow into a Task with compacted arguments

Trait Implementations

impl Debug for TaskRow

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

Formats the value using the given formatter.