Struct Task 

pub struct Task {

    pub id: TaskId,
    pub name: String,
    pub task_type: String,
    pub priority: i32,
    pub payload: Vec<u8>,
    pub dependencies: Vec<TaskId>,
    pub estimated_duration: Option<Duration>,
    pub resources: ResourceRequirements,
    pub locality_hints: Vec<String>,
    pub created_at: Instant,
    pub scheduled_at: Option<Instant>,
    pub started_at: Option<Instant>,
    pub completed_at: Option<Instant>,
    pub status: TaskStatus,
    pub result: Option<TaskResult>,
    pub error: Option<String>,
    pub retry_count: u32,
    pub checkpoint: Option<Vec<u8>>,
}

A task in the task graph.

Fields

id: TaskId

Unique task ID

name: String

Task name

task_type: String

Task type

priority: i32

Task priority (higher = more important)

payload: Vec<u8>

Task payload (serialized data)

dependencies: Vec<TaskId>

Dependencies (tasks that must complete before this one)

estimated_duration: Option<Duration>

Estimated execution time

resources: ResourceRequirements

Resource requirements

locality_hints: Vec<String>

Data locality hints (preferred worker IDs)

created_at: Instant

Creation timestamp

scheduled_at: Option<Instant>

Scheduled timestamp

started_at: Option<Instant>

Started timestamp

completed_at: Option<Instant>

Completed timestamp

status: TaskStatus

Task status

result: Option<TaskResult>

Result (if completed)

error: Option<String>

Error (if failed)

retry_count: u32

Number of retry attempts

checkpoint: Option<Vec<u8>>

Checkpoint data

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Task

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

Formats the value using the given formatter.