Airflow Summit 2025 is coming October 07-09. Register now for early bird ticket!

airflow.providers.openlineage.plugins.listener

Classes

OpenLineageListener

OpenLineage listener sends events on task instance and dag run starts, completes and failures.

Functions

get_openlineage_listener()

Get singleton listener manager.

Module Contents

class airflow.providers.openlineage.plugins.listener.OpenLineageListener[source]

OpenLineage listener sends events on task instance and dag run starts, completes and failures.

log[source]
extractor_manager[source]
adapter[source]
on_task_instance_running(previous_state, task_instance)[source]
on_task_instance_success(previous_state, task_instance)[source]
on_task_instance_failed(previous_state, task_instance, error)[source]
property executor: concurrent.futures.ProcessPoolExecutor[source]
on_starting(component)[source]
before_stopping(component)[source]
on_dag_run_running(dag_run, msg)[source]
on_dag_run_success(dag_run, msg)[source]
on_dag_run_failed(dag_run, msg)[source]
submit_callable(callable, *args, **kwargs)[source]
log_submit_error(fut)[source]
airflow.providers.openlineage.plugins.listener.get_openlineage_listener()[source]

Get singleton listener manager.

Was this entry helpful?