Enum WorkflowEvent 

pub enum WorkflowEvent {
    NodeStart {
        node_name: String,
        step_index: usize,
    },
    NodeEnd {
        node_name: String,
        step_index: usize,
        elapsed: Duration,
    },
    Token {
        node_name: String,
        token: String,
    },
    NodeError {
        node_name: String,
        error: String,
    },
    Completed {
        result: String,
        total_steps: usize,
        elapsed: Duration,
    },
}

Step-by-step events emitted during workflow execution.

Obtain a BoxStream<WorkflowEvent> via Workflow::run_stream for realtime UI updates, progress bars, logging, etc.

Variants

NodeStart

Node started execution

Fields

node_name: String

step_index: usize

NodeEnd

Node finished execution

Fields

node_name: String

step_index: usize

elapsed: Duration

Token

Token produced by node (forwarded during streaming agent output)

Fields

node_name: String

token: String

NodeError

Node execution error (non-fatal; error is recorded but stream continues)

Fields

node_name: String

error: String

Completed

Workflow execution completed

Fields

result: String

total_steps: usize

elapsed: Duration

Trait Implementations

impl Clone for WorkflowEvent

fn clone(&self) -> WorkflowEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowEvent

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

Formats the value using the given formatter.