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

Question

我刚刚将 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，但事实并非如此，所以我对发生的事情感到非常困惑。

Answer 1

EmptyOperator在 Airflow 2.3.0 中发布。

在 Airflow 2.3.0 中DummyOperator已弃用，取而代之EmptyOperator（参见PR）

对于 Airflow>=2.3.0，您应该使用EmptyOperator：

from airflow.operators.empty import EmptyOperator

对于 Airflow<2.3.0 您应该使用DummyOperator：

from airflow.operators.dummy import DummyOperator