此错误是由于2.0版本中删除了DUMMY OPERATOR。您需要替换为最新版本的DummyOperator。
示例代码:
从:
from airflow.operators.dummy_operator import DummyOperator op = DummyOperator(task_id='my_task')
改为:
from airflow.operators.bash_operator import DummyOperator op = DummyOperator(task_id='my_task')
上一篇:Airflow生成的事件列表