airflow.providers.openlineage.utils.selective_enable

Module Contents

Functions

enable_lineage(obj)

Set selective enable OpenLineage parameter to True.

disable_lineage(obj)

Set selective enable OpenLineage parameter to False.

is_task_lineage_enabled(task)

Check if selective enable OpenLineage parameter is set to True on task level.

is_dag_lineage_enabled(dag)

Check if DAG is selectively enabled to emit OpenLineage events.

Attributes

ENABLE_OL_PARAM_NAME

ENABLE_OL_PARAM

DISABLE_OL_PARAM

T

log

airflow.providers.openlineage.utils.selective_enable.ENABLE_OL_PARAM_NAME = '_selective_enable_ol'[source]
airflow.providers.openlineage.utils.selective_enable.ENABLE_OL_PARAM[source]
airflow.providers.openlineage.utils.selective_enable.DISABLE_OL_PARAM[source]
airflow.providers.openlineage.utils.selective_enable.T[source]
airflow.providers.openlineage.utils.selective_enable.log[source]
airflow.providers.openlineage.utils.selective_enable.enable_lineage(obj)[source]

Set selective enable OpenLineage parameter to True.

The method also propagates param to tasks if the object is DAG.

airflow.providers.openlineage.utils.selective_enable.disable_lineage(obj)[source]

Set selective enable OpenLineage parameter to False.

The method also propagates param to tasks if the object is DAG.

airflow.providers.openlineage.utils.selective_enable.is_task_lineage_enabled(task)[source]

Check if selective enable OpenLineage parameter is set to True on task level.

airflow.providers.openlineage.utils.selective_enable.is_dag_lineage_enabled(dag)[source]

Check if DAG is selectively enabled to emit OpenLineage events.

The method also checks if selective enable parameter is set to True or if any of the tasks in DAG is selectively enabled.

Was this entry helpful?