`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'[源代码]¶

airflow.providers.openlineage.utils.selective_enable.enable_lineage(obj)[源代码]¶

将选择性启用 OpenLineage 参数设置为 True。

如果对象是 DAG，该方法还会将参数传播到任务。

airflow.providers.openlineage.utils.selective_enable.disable_lineage(obj)[源代码]¶

将选择性启用 OpenLineage 参数设置为 False。

如果对象是 DAG，该方法还会将参数传播到任务。

airflow.providers.openlineage.utils.selective_enable.is_task_lineage_enabled(task)[源代码]¶

检查任务级别的选择性启用 OpenLineage 参数是否设置为 True。

airflow.providers.openlineage.utils.selective_enable.is_dag_lineage_enabled(dag)[源代码]¶

检查 DAG 是否被选择性启用以发送 OpenLineage 事件。

该方法还会检查选择性启用参数是否设置为 True，或者 DAG 中的任何任务是否被选择性启用。