airflow.providers.openlineage.utils.selective_enable¶

Attributes¶

`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.

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.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.