Struct WorkflowTotals 

pub struct WorkflowTotals {
    pub total_input_tokens: u64,
    pub total_output_tokens: u64,
    pub total_cached_input_tokens: u64,
    pub total_thinking_tokens: u64,
    pub total_tool_tokens: u64,
    pub total_cost_usd: f64,
    pub task_count: u32,
}

Aggregate token + cost rollup emitted on EngineEvent::WorkflowEnd.

Issue #1173: today’s WorkflowEnd carries just the workflow’s return value, so dashboards and the CLI re-walk every TaskEnd to compute per-execution totals. This struct surfaces the same numbers once on the terminating event so consumers can size the run without parsing the full event log.

The engine populates this by summing TokenUsage fields across every TaskEnd emitted in the workflow scope. Sub-script TaskEnds (events wrapped inside EngineEvent::SubScript) DO contribute — the engine relay forwards them to the parent counter so a chain’s outer WorkflowEnd reflects the entire chain’s spend.

total_cost_usd is the only field the engine can’t always populate on its own — pricing tables live in akribes-server to keep akribes-core free of provider rate metadata. The field defaults to 0.0 and stays 0.0 when the engine has no cost data; downstream enrichers may overwrite it on the server side before persistence.

Fields

total_input_tokens: u64

Sum of TokenUsage::input_tokens across every TaskEnd in the workflow scope (including sub-script TaskEnds). Superset of cached + cache-write — see TokenUsage for the convention.

total_output_tokens: u64

Sum of TokenUsage::output_tokens.

total_cached_input_tokens: u64

Sum of TokenUsage::cached_input_tokens (cache READS).

total_thinking_tokens: u64

Sum of TokenUsage::reasoning_tokens (extended thinking / reasoning tokens — a SUBSET of total_output_tokens).

total_tool_tokens: u64

Tokens spent on tool-call traffic. Reserved for future per-tool breakdown — the engine doesn’t track this separately today, so it stays 0. Present on the wire so SDKs can render the slot without a schema bump when the engine starts populating it.

total_cost_usd: f64

Sum of per-task USD cost. Always 0.0 when emitted by the engine — pricing lives in akribes-server. Server-side enrichment may overwrite before persistence.

task_count: u32

Number of TaskEnd events folded into the totals above.

Implementations

impl WorkflowTotals

pub fn accumulate(&mut self, usage: Option<&TokenUsage>)

Fold a single TokenUsage into the running totals. No-op for None so the engine can call it on every TaskEnd without branching on the optional usage field.

pub fn merge(&mut self, other: &WorkflowTotals)

Merge another WorkflowTotals (e.g. from a sub-script) into self. Used by the engine when the relay surfaces a child workflow’s rollup — the outer chain’s totals subsume every sub-script’s.

Trait Implementations

impl Clone for WorkflowTotals

fn clone(&self) -> WorkflowTotals

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowTotals

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

Formats the value using the given formatter.

impl Default for WorkflowTotals

fn default() -> WorkflowTotals

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for WorkflowTotals

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for WorkflowTotals

fn eq(&self, other: &WorkflowTotals) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for WorkflowTotals

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for WorkflowTotals