我刚刚将 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(使用前将#替换为@)