Struct RunEvent 

pub struct RunEvent {
    pub event_type: RunEventType,
    pub event_time: String,
    pub run: Run,
    pub job: Job,
    pub inputs: Vec<Dataset>,
    pub outputs: Vec<Dataset>,
    pub producer: String,
    pub schema_url: String,
}

A single OpenLineage run event.

All events for one query share a constant Run::run_id; eventType distinguishes START from COMPLETE/FAIL.

Fields

event_type: RunEventType

Lifecycle stage this event reports.

event_time: String

RFC3339 timestamp.

run: Run

The run this event belongs to.

job: Job

The job the run is an execution of.

inputs: Vec<Dataset>

Datasets consumed by the run.

outputs: Vec<Dataset>

Datasets produced by the run.

producer: String

URI identifying the software that emitted the event.

schema_url: String

URL of the OpenLineage schema this event conforms to.

Trait Implementations

impl Clone for RunEvent

fn clone(&self) -> RunEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RunEvent

fn deserialize<__D>( __deserializer: __D, ) -> Result<RunEvent, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RunEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.