Struct JobProgress 

pub struct JobProgress {
    pub run_id: String,
    pub status: RunStatus,
    pub stdout_chunk: Option<String>,
    pub stderr_chunk: Option<String>,
    pub exit_code: Option<i32>,
}

Push payload for jobs.progress. Sent on:

• first move from Queued → Running
• each stdout / stderr chunk (split to fit the 1 MiB framing cap — SPEC §2.12.2)
• terminal state transition (Completed / Failed / Killed) with exit_code populated

The reference shape is SPEC §2.12.11’s JobProgress struct.

Fields

run_id: String

The run_id minted by jobs.execute.

status: RunStatus

stdout_chunk: Option<String>

Newly-produced stdout, UTF-8 decoded (tolerant — see kanade-agent::process::capture_tolerant). None when this push is a pure status transition; Some("") would never be emitted (the agent omits the field instead).

stderr_chunk: Option<String>

Newly-produced stderr. Same conventions as stdout_chunk.

exit_code: Option<i32>

Populated on the terminal push only. Agents stamp the actual process exit code from the child. Synthetic non-process outcomes (timeout, remote kill) are surfaced as Some(-1) with the status field carrying the distinguishing information (Failed / Killed), not via a reserved exit-code number.

Note: the sibling ExecResult wire (manifest exec → backend, NOT this KLP flow) DOES partition synthetic skip codes (124 / 125 / 126 / 127) for the agent’s pre-exec staleness gates. See the doc on kanade-agent::commands::publish_staleness_skipped for the table. JobProgress’s exit_code does not share that partition.

Trait Implementations

impl Clone for JobProgress

fn clone(&self) -> JobProgress

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JobProgress

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for JobProgress

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for JobProgress

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Serialize for JobProgress

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

where __S: Serializer,

Serialize this value into the given Serde serializer.