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 中的任何任务是否被选择性启用。