openlineage_python_client_start_runevent_emit_quickstart.py

1import uuid
2from datetime import datetime
3from openlineage.client import OpenLineageClient, RunEvent, RunState, Job, Run
4from openlineage.client.facet import NominalTimeRunFacet
5
6# Initialize the client (uses environment variables for transport configuration by default)
7client = OpenLineageClient()
8
9# Define the job and run information
10job = Job(namespace="my_namespace", name="my_job")
11run = Run(runId=str(uuid.uuid4()), facets={
12    "nominalTime": NominalTimeRunFacet(
13        nominalStartTime=datetime.now().isoformat(),
14        nominalEndTime=datetime.now().isoformat()
15    )
16})
17
18# Create a RunEvent
19event = RunEvent(
20    eventType=RunState.START,
21    eventTime=datetime.now().isoformat(),
22    run=run,
23    job=job,
24    producer="https://github.com/OpenLineage/OpenLineage/client/python"
25)
26
27# Emit the event
28client.emit(event)