Struct TaskState 

pub struct TaskState {
    pub id: TaskId,
    pub spec: TaskSpec,
    pub status: TaskStatus,
    pub attempt: u32,
    pub suspended_on: Option<ResumeKey>,
    pub last_result: Option<Value>,
    pub created_at: u64,
    pub updated_at: u64,
    pub spawn_depth: u32,
}

The full mutable record of one task: its static spec, current status, attempt counter, and bookkeeping timestamps. Cloned out of EngineState on every read (e.g. by read_task_state / poll_task).

Fields

id: TaskId

Unique task identifier (assigned by start_task).

spec: TaskSpec

The static spec this task was created from.

status: TaskStatus

Current lifecycle status.

attempt: u32

1-based counter, bumped by Engine::dispatch_attempt_with each time this task is dispatched.

suspended_on: Option<ResumeKey>

Set while status == Suspended; the key needed to resume it.

last_result: Option<Value>

Most recent result value posted via post_result or produced by a completed attempt.

created_at: u64

Unix timestamp (seconds) when the task was created.

updated_at: u64

Unix timestamp (seconds) of the last state mutation.

spawn_depth: u32

Recursive swarm depth. The root (an Operator calling start_task) is 0; a child spawned by a Worker calling start_task is its parent’s depth + 1. Exceeding EngineCfg.max_spawn_depth raises SpawnDepthExceeded.

Implementations

impl TaskState

pub fn new(id: TaskId, spec: TaskSpec) -> Self

Construct a new Pending task with attempt = 0 and spawn_depth = 0; created_at/updated_at are set to now.

Trait Implementations

impl Clone for TaskState

fn clone(&self) -> TaskState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TaskState

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TaskState

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

where __S: Serializer,

Serialize this value into the given Serde serializer.