Struct ExecutionEvent 

pub struct ExecutionEvent {
    pub id: EventId,
    pub execution_id: ExecutionId,
    pub workflow_id: WorkflowId,
    pub node_id: Option<NodeId>,
    pub timestamp: DateTime<Utc>,
    pub event_type: EventType,
    pub details: EventDetails,
}

Execution event tracking node-level and workflow-level activities

Fields

id: EventId

Unique event identifier

execution_id: ExecutionId

Execution this event belongs to

workflow_id: WorkflowId

Workflow being executed

node_id: Option<NodeId>

Node associated with this event (if applicable)

timestamp: DateTime<Utc>

Event timestamp

event_type: EventType

Event type classification

details: EventDetails

Detailed event information

Implementations

impl ExecutionEvent

pub fn workflow_started( execution_id: ExecutionId, workflow_id: WorkflowId, metadata: WorkflowMetadata, input: HashMap<String, Value>, ) -> Self

Create a new workflow started event

pub fn workflow_completed( execution_id: ExecutionId, workflow_id: WorkflowId, duration_ms: u64, result: ExecutionResult, ) -> Self

Create a new workflow completed event

pub fn workflow_failed( execution_id: ExecutionId, workflow_id: WorkflowId, duration_ms: u64, error: String, stack_trace: Option<String>, ) -> Self

Create a new workflow failed event

pub fn workflow_cancelled( execution_id: ExecutionId, workflow_id: WorkflowId, duration_ms: u64, reason: String, ) -> Self

Create a new workflow cancelled event

pub fn node_started( execution_id: ExecutionId, workflow_id: WorkflowId, node_id: NodeId, node_kind: NodeKind, input: HashMap<String, Value>, ) -> Self

Create a new node started event

pub fn node_completed( execution_id: ExecutionId, workflow_id: WorkflowId, node_id: NodeId, node_kind: NodeKind, duration_ms: u64, metrics: NodeMetrics, output: HashMap<String, Value>, ) -> Self

Create a new node completed event

pub fn node_failed( execution_id: ExecutionId, workflow_id: WorkflowId, node_id: NodeId, node_kind: NodeKind, error: String, stack_trace: Option<String>, retry_attempt: u32, ) -> Self

Create a new node failed event

pub fn node_skipped( execution_id: ExecutionId, workflow_id: WorkflowId, node_id: NodeId, node_kind: NodeKind, reason: String, ) -> Self

Create a new node skipped event

pub fn variable_changed( execution_id: ExecutionId, workflow_id: WorkflowId, node_id: Option<NodeId>, variable_name: String, old_value: Option<Value>, new_value: Value, source: String, ) -> Self

Create a new variable changed event

pub fn error_occurred( execution_id: ExecutionId, workflow_id: WorkflowId, node_id: Option<NodeId>, error: String, stack_trace: Option<String>, context: HashMap<String, Value>, ) -> Self

Create a new error occurred event

pub fn checkpoint_created( execution_id: ExecutionId, workflow_id: WorkflowId, checkpoint_id: String, nodes_completed: usize, state: String, ) -> Self

Create a new checkpoint created event

pub fn execution_resumed( execution_id: ExecutionId, workflow_id: WorkflowId, checkpoint_id: String, nodes_to_skip: usize, ) -> Self

Create a new execution resumed event

Trait Implementations

impl Clone for ExecutionEvent

fn clone(&self) -> ExecutionEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ExecutionEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExecutionEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.