Package index

Overview

openlineage openlineage-package

Create and Emit OpenLineage Events

Events and models

RunEvent()

OpenLineage run event

RunState()

OpenLineage run state

Run()

OpenLineage run

Job()

OpenLineage job

Dataset() InputDataset() OutputDataset()

OpenLineage datasets

Facets

ol_facet()

Create a generic OpenLineage facet

NominalTimeRunFacet() ParentRunFacet() ErrorMessageRunFacet() ProcessingEngineRunFacet()

Typed run facets

SQLJobFacet() SourceCodeLocationJobFacet() EmissionPattern() JobTypeJobFacet()

Typed job facets

SchemaField() SchemaDatasetFacet() DatasourceDatasetFacet()

Typed dataset facets

InputStatisticsInputDatasetFacet() OutputStatisticsOutputDatasetFacet()

Input and output statistics facets

ol_tag()

Create an OpenLineage tag

TagsJobFacet() TagsRunFacet() TagsDatasetFacet()

Typed tags facets

Serialization

as_openlineage_list()

Convert an OpenLineage value to its wire representation

to_openlineage_json()

Serialize an OpenLineage value to JSON

Client and transports

OpenLineageClient

OpenLineage client

local_transports AccumulatingTransport ConsoleTransport NoopTransport

Local OpenLineage transports

HttpTransport

Synchronous HTTP transport

Event utilities

new_run_id()

Generate a run identifier

new_event_time()

Format an OpenLineage event time

OPENLINEAGE_SCHEMA_VERSION OPENLINEAGE_SCHEMA_URL OPENLINEAGE_RUN_EVENT_SCHEMA_URL OPENLINEAGE_PRODUCER

OpenLineage protocol constants