`airflow.providers.openlineage.utils.selective_enable`¶

模組內容¶

`enable_lineage`(obj)	將選擇性啟用 OpenLineage 參數設定為 True。
`disable_lineage`(obj)	將選擇性啟用 OpenLineage 參數設定為 False。
`is_task_lineage_enabled`(task)	檢查是否在任務層級將選擇性啟用 OpenLineage 參數設定為 True。
`is_dag_lineage_enabled`(dag)	檢查 DAG 是否已選擇性啟用以發送 OpenLineage 事件。

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]¶

將選擇性啟用 OpenLineage 參數設定為 True。

如果物件是 DAG，此方法也會將參數傳播到任務。

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

將選擇性啟用 OpenLineage 參數設定為 False。

如果物件是 DAG，此方法也會將參數傳播到任務。

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

檢查是否在任務層級將選擇性啟用 OpenLineage 參數設定為 True。

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

檢查 DAG 是否已選擇性啟用以發送 OpenLineage 事件。

此方法也會檢查是否已將選擇性啟用參數設定為 True，或 DAG 中的任何任務是否已選擇性啟用。