Enum GraphEvent 

pub enum GraphEvent {
    RunStart {
        run_id: String,
        trace_id: String,
        trace_ctx: Option<TraceCtx>,
        graph_name: Option<String>,
    },
    RunEnd {
        run_id: String,
        trace_id: String,
        trace_ctx: Option<TraceCtx>,
    },
    NodeStart {
        run_id: String,
        trace_id: String,
        trace_ctx: Option<TraceCtx>,
        node_id: String,
        attempt: u32,
        attempt_id: Option<AttemptId>,
        trial_id: Option<TrialId>,
    },
    NodeEnd {
        run_id: String,
        trace_id: String,
        trace_ctx: Option<TraceCtx>,
        node_id: String,
        outcome: NodeOutcomeKind,
        attempt_id: Option<AttemptId>,
        trial_id: Option<TrialId>,
    },
    Token {
        run_id: String,
        trace_id: String,
        trace_ctx: Option<TraceCtx>,
        node_id: String,
        token: String,
    },
    CheckpointWritten {
        run_id: String,
        trace_id: String,
        trace_ctx: Option<TraceCtx>,
        checkpoint_attempt_id: String,
    },
    InterruptRaised {
        run_id: String,
        trace_id: String,
        trace_ctx: Option<TraceCtx>,
        node_id: String,
        kind: String,
        payload: Value,
    },
    StateUpdate {
        run_id: String,
        trace_id: String,
        trace_ctx: Option<TraceCtx>,
        node_id: String,
        updates: HashMap<String, Value>,
    },
    SuperstepStart {
        run_id: String,
        trace_id: String,
        trace_ctx: Option<TraceCtx>,
        step: usize,
        nodes: Vec<String>,
    },
    SuperstepEnd {
        run_id: String,
        trace_id: String,
        trace_ctx: Option<TraceCtx>,
        step: usize,
    },
    ParallelCancellation {
        run_id: String,
        trace_id: String,
        trace_ctx: Option<TraceCtx>,
        external_effects_may_have_escaped: bool,
    },
}

Structured runtime event emitted during graph execution.

Every variant carries both legacy and canonical trace/retry fields:

• trace_id: String — legacy correlation ID.
• trace_ctx: Option<stack_ids::TraceCtx> — canonical trace context.
• attempt: u32 / attempt_id: Option<stack_ids::AttemptId> — retry family.
• trial_id: Option<stack_ids::TrialId> — individual execution trial (on variants representing a single execution attempt).

Legacy field phase status: compatibility / migration-only

The trace_id: String and attempt: u32 fields use primitive types for backward compatibility. The canonical replacements are stack_ids::TraceCtx, stack_ids::AttemptId, and stack_ids::TrialId.

Removal condition: legacy fields removed when all event consumers migrate.

Variants

RunStart

A graph run started.

Fields

run_id: String

trace_id: String

👎Deprecated:

Use trace_ctx/attempt_id/trial_id instead. Will be removed when all consumers migrate.

Phase status: compatibility / migration-only. Removal condition: all consumers migrate to trace_ctx/attempt_id/trial_id.

trace_ctx: Option<TraceCtx>

graph_name: Option<String>

RunEnd

A graph run ended.

Fields

run_id: String

trace_id: String

👎Deprecated:

Use trace_ctx/attempt_id/trial_id instead. Will be removed when all consumers migrate.

Phase status: compatibility / migration-only. Removal condition: all consumers migrate to trace_ctx/attempt_id/trial_id.

trace_ctx: Option<TraceCtx>

NodeStart

A node execution attempt started.

Fields

run_id: String

trace_id: String

👎Deprecated:

Use trace_ctx/attempt_id/trial_id instead. Will be removed when all consumers migrate.

Phase status: compatibility / migration-only. Removal condition: all consumers migrate to trace_ctx/attempt_id/trial_id.

trace_ctx: Option<TraceCtx>

node_id: String

attempt: u32

👎Deprecated:

Use trace_ctx/attempt_id/trial_id instead. Will be removed when all consumers migrate.

Phase status: compatibility / migration-only. Removal condition: all consumers migrate to trace_ctx/attempt_id/trial_id.

attempt_id: Option<AttemptId>

trial_id: Option<TrialId>

NodeEnd

A node execution attempt ended.

Fields

run_id: String

trace_id: String

👎Deprecated:

Use trace_ctx/attempt_id/trial_id instead. Will be removed when all consumers migrate.

Phase status: compatibility / migration-only. Removal condition: all consumers migrate to trace_ctx/attempt_id/trial_id.

trace_ctx: Option<TraceCtx>

node_id: String

outcome: NodeOutcomeKind

attempt_id: Option<AttemptId>

trial_id: Option<TrialId>

Token

A streaming token from a payload node.

Fields

run_id: String

trace_id: String

👎Deprecated:

Use trace_ctx/attempt_id/trial_id instead. Will be removed when all consumers migrate.

Phase status: compatibility / migration-only. Removal condition: all consumers migrate to trace_ctx/attempt_id/trial_id.

trace_ctx: Option<TraceCtx>

node_id: String

token: String

CheckpointWritten

A checkpoint was written.

Fields

run_id: String

trace_id: String

👎Deprecated:

Use trace_ctx/attempt_id/trial_id instead. Will be removed when all consumers migrate.

Phase status: compatibility / migration-only. Removal condition: all consumers migrate to trace_ctx/attempt_id/trial_id.

trace_ctx: Option<TraceCtx>

checkpoint_attempt_id: String

The checkpoint-level attempt ID (distinct from stack_ids::AttemptId).

InterruptRaised

An interrupt was raised by a node.

Fields

run_id: String

trace_id: String

👎Deprecated:

Use trace_ctx/attempt_id/trial_id instead. Will be removed when all consumers migrate.

Phase status: compatibility / migration-only. Removal condition: all consumers migrate to trace_ctx/attempt_id/trial_id.

trace_ctx: Option<TraceCtx>

node_id: String

kind: String

payload: Value

StateUpdate

State was updated by a node.

Fields

run_id: String

trace_id: String

👎Deprecated:

Use trace_ctx/attempt_id/trial_id instead. Will be removed when all consumers migrate.

Phase status: compatibility / migration-only. Removal condition: all consumers migrate to trace_ctx/attempt_id/trial_id.

trace_ctx: Option<TraceCtx>

node_id: String

updates: HashMap<String, Value>

SuperstepStart

A parallel superstep started.

Fields

run_id: String

trace_id: String

👎Deprecated:

Use trace_ctx/attempt_id/trial_id instead. Will be removed when all consumers migrate.

Phase status: compatibility / migration-only. Removal condition: all consumers migrate to trace_ctx/attempt_id/trial_id.

trace_ctx: Option<TraceCtx>

step: usize

nodes: Vec<String>

SuperstepEnd

A parallel superstep ended.

Fields

run_id: String

trace_id: String

👎Deprecated:

Use trace_ctx/attempt_id/trial_id instead. Will be removed when all consumers migrate.

Phase status: compatibility / migration-only. Removal condition: all consumers migrate to trace_ctx/attempt_id/trial_id.

trace_ctx: Option<TraceCtx>

step: usize

ParallelCancellation

Remaining parallel branches were cancelled after a sibling failed.

Fields

run_id: String

trace_id: String

👎Deprecated:

Use trace_ctx instead.

trace_ctx: Option<TraceCtx>

external_effects_may_have_escaped: bool

Cancellation cannot undo effects already handed to external systems.

Trait Implementations

impl Clone for GraphEvent

fn clone(&self) -> GraphEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GraphEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for GraphEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for GraphEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.