如何导入 2.2.5 版本的 Airflow 运算符?

2024-02-16

我刚刚将 Airflow 升级到 2.2.5,但无法使用 EmptyOperator。应该很简单from airflow.operators.empty import EmptyOperator但我得到了错误ModuleNotFoundError: No module named 'airflow.operators.empty'。我也尝试过:

from airflow.operators import empty
from empty.operators import EmptyOperator

Airflow 存储库本身显示的结构意味着from airflow.operators.empty import EmptyOperator应该有效,但事实并非如此,所以我真的很困惑到底发生了什么。


EmptyOperator在 Airflow 2.3.0 中发布。

在气流2.3.0中DummyOperator已被弃用,有利于EmptyOperator (See PR https://github.com/apache/airflow/pull/22832)

对于 Airflow>=2.3.0 你应该使用EmptyOperator:

from airflow.operators.empty import EmptyOperator

对于 AirflowDummyOperator:

from airflow.operators.dummy import DummyOperator
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如何导入 2.2.5 版本的 Airflow 运算符? 的相关文章

随机推荐