airflow.providers.openlineage.plugins.listener

Attributes

setproctitle

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

airflow.providers.openlineage.plugins.listener.setproctitle[source]
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?