Struct RunProgress 

pub struct RunProgress {
    pub current_phase: Option<String>,
    pub phases: Vec<PhaseProgress>,
    pub agents_started: u64,
    pub agents_finished: u64,
    pub agents_replayed: u64,
    pub agents_skipped: u64,
    pub agents_failed: u64,
    pub log_lines: u64,
    pub total_tokens: TokenUsage,
}

A point-in-time snapshot of a workflow run’s progress.

Fields

current_phase: Option<String>

The most recently started phase, if any.

phases: Vec<PhaseProgress>

One entry per phase, in start order.

agents_started: u64

Total agents issued (across all phases and the no-phase default).

agents_finished: u64

Agents that completed live.

agents_replayed: u64

Agents whose output was replayed from the resume journal.

agents_skipped: u64

Agents skipped (e.g. cancelled mid-run).

agents_failed: u64

Agents that failed with an agent-domain error.

log_lines: u64

Count of log() lines emitted.

total_tokens: TokenUsage

Accumulated token usage across finished + replayed agents.

Implementations

impl RunProgress

pub fn apply(&mut self, event: &WorkflowEvent)

Fold one WorkflowEvent into this snapshot.

The match is intentionally exhaustive (no _ arm): because this lives in the same crate as WorkflowEvent, adding a variant there makes this fail to compile until a handling decision is made here.

Trait Implementations

impl Clone for RunProgress

fn clone(&self) -> RunProgress

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunProgress

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

Formats the value using the given formatter.

impl Default for RunProgress

fn default() -> RunProgress

Returns the “default value” for a type.