Struct SessionTaskUpdate 

pub struct SessionTaskUpdate {

    pub state: Option<SessionTaskState>,
    pub state_detail: Option<String>,
    pub progress: Option<TaskProgress>,
    pub input_request: Option<TaskInputRequest>,
    pub summary: Option<String>,
    pub result_path: Option<String>,
    pub artifacts: Option<Vec<TaskArtifact>>,
    pub append_artifact: Option<TaskArtifact>,
    pub error: Option<TaskError>,
    pub links: Option<TaskLinks>,
    pub worker_id: Option<String>,
    pub heartbeat_at: Option<DateTime<Utc>>,
    pub expected_attempt: Option<i32>,
    pub increment_attempt: bool,
}

Partial update applied through apply_task_update. None = unchanged.

Fields

state: Option<SessionTaskState>

state_detail: Option<String>

progress: Option<TaskProgress>

input_request: Option<TaskInputRequest>

Setting an input request implies awaiting_input.

summary: Option<String>

result_path: Option<String>

artifacts: Option<Vec<TaskArtifact>>

Replaces the artifact list when set.

append_artifact: Option<TaskArtifact>

Append one artifact under the registry’s update lock, after any replacement. Avoids losing concurrent sink reports through read/modify/write snapshots.

error: Option<TaskError>

links: Option<TaskLinks>

Merged field-by-field into existing links.

worker_id: Option<String>

heartbeat_at: Option<DateTime<Utc>>

Liveness heartbeat timestamp.

expected_attempt: Option<i32>

Stale-attempt fence: when set, the update is silently ignored if task.attempt != expected_attempt. Executors and sinks set this to the attempt they captured at start; the reaper bumps attempt (via increment_attempt) when it fails an orphan, so a zombie executor’s later writes are rejected. Writers that do not track attempts (e.g. cancel_task from the API) leave this None.

increment_attempt: bool

Supersede the current attempt: bumps task.attempt so writes fenced on the previous attempt are rejected from now on. Set by the reaper when it fails an orphaned task. Ignored if the update itself is dropped by the fence or the terminal-state invariant.

Trait Implementations

impl Clone for SessionTaskUpdate

fn clone(&self) -> SessionTaskUpdate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SessionTaskUpdate

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

Formats the value using the given formatter.

impl Default for SessionTaskUpdate

fn default() -> SessionTaskUpdate

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SessionTaskUpdate

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SessionTaskUpdate

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

where __S: Serializer,

Serialize this value into the given Serde serializer.