Struct PipelineRunInfo 

pub struct PipelineRunInfo {
    pub run_id: Uuid,
    pub pipeline_id: Uuid,
    pub pipeline_name: String,
    pub user_id: Option<Uuid>,
    pub tenant_id: Option<Uuid>,
    pub dataset_id: Option<Uuid>,
    pub data_ids: Vec<Uuid>,
    pub status: PipelineRunStatus,
    pub started_at: DateTime<Utc>,
    pub completed_at: Option<DateTime<Utc>>,
}

Identity and metadata of a pipeline run, passed to PipelineWatcher event methods.

Fields

run_id: Uuid

Random per-invocation ID.

pipeline_id: Uuid

Deterministic ID: uuid5(user_id + name + dataset_id). Falls back to run_id when not enough info is available.

pipeline_name: String

Human-readable pipeline name.

user_id: Option<Uuid>

Owner / tenant.

tenant_id: Option<Uuid>

Tenant the pipeline run belongs to. None for single-user deployments. Emitted as "Single User Tenant" on the wire when None (Python parity).

dataset_id: Option<Uuid>

Dataset being processed.

data_ids: Vec<Uuid>

Data.ids for the inputs of the run. Surfaced into run_info["data"] by the watcher. Empty when the run has no Data input.

status: PipelineRunStatus

Current run status.

started_at: DateTime<Utc>

When the run was initiated.

completed_at: Option<DateTime<Utc>>

When the run reached a terminal state (Completed or Errored). None while the run is still in flight.

Implementations

impl PipelineRunInfo

pub fn elapsed_seconds(&self) -> Option<f64>

Wall-clock seconds between Self::started_at and Self::completed_at. Returns None while the run is still in flight (i.e. completed_at is unset).

Trait Implementations

impl Clone for PipelineRunInfo

fn clone(&self) -> PipelineRunInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineRunInfo

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

Formats the value using the given formatter.