airflow.providers.openlineage.plugins.listener

Module Contents

Classes

OpenLineageListener

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

Functions

get_openlineage_listener()

Get singleton listener manager.
class airflow.providers.openlineage.plugins.listener.OpenLineageListener[source]

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

property executor[source]
on_task_instance_running(previous_state, task_instance, session)[source]
on_task_instance_success(previous_state, task_instance, session)[source]
on_task_instance_failed(previous_state, task_instance, session)[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]
airflow.providers.openlineage.plugins.listener.get_openlineage_listener()[source]

Get singleton listener manager.

Was this entry helpful?