Struct RunContext 

pub struct RunContext {
    pub run_id: Option<String>,
    pub invocation_id: Option<String>,
    pub started_at: Option<DateTime<Utc>>,
    pub finished_at: Option<DateTime<Utc>>,
    pub duration: Option<Duration>,
}

Available on crate feature notify only.

Run identity + timing for the invocation an event belongs to (#480).

Built once per invocation at the emit site and stamped onto every event that invocation produces, so a receiver can correlate a notification back to the run it triggered. Before this existed the only correlation keys in the payload were pipeline + row, which are not unique per run — two overlapping runs of one pipeline (a schedule overlap: queue, a cluster with several workers, a backfill fanning out per window) produced indistinguishable callbacks and a receiver keying off pipeline would mis-attribute status.

duration is measured from a monotonic Instant, never by subtracting the two wall-clock stamps — an NTP step between them would otherwise yield a negative duration.

Fields

run_id: Option<String>

Correlation id for the submitted run. Under faucet serve this is the serve run id returned by POST /v1/runs; otherwise the invocation’s own generated id. A matrix run’s rows all share one run_id and are told apart by row (and by invocation_id).

invocation_id: Option<String>

This single invocation’s id. Distinct per matrix row within one run.

started_at: Option<DateTime<Utc>>

When the invocation started (UTC).

finished_at: Option<DateTime<Utc>>

When the invocation reached its terminal state (UTC).

duration: Option<Duration>

Monotonic elapsed wall-clock for the invocation.

Implementations

impl RunContext

pub fn start(run_id: Option<String>, invocation_id: Option<String>) -> Self

Open a context at “now”, carrying the run/invocation identity. Call finish when the invocation reaches a terminal state.

pub fn finish(self, since: Instant) -> Self

Close the context, stamping finished_at and the monotonic duration measured from since.

Trait Implementations

impl Clone for RunContext

fn clone(&self) -> RunContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunContext

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

Formats the value using the given formatter.

impl Default for RunContext

fn default() -> RunContext

Returns the “default value” for a type.