在VS Code中运行Airflow DAG代码时遇ImportError：无法导入DummyOperator

问题详情 #

运行Airflow DAG代码时触发导入错误：

ImportError: cannot import name 'DummyOperator' from 'airflow.operators' (c:\Users\10679196\AppData\Local\Programs\Python\Python38\lib\site-packages\airflow\operators_init_.py)

当前使用的导入代码：

from airflow import DAG
from airflow.operators import DummyOperator

环境版本信息：

• apache-airflow: 2.4.2
• python: 3.8.1
• pip: 22.3

解决方法 #

Airflow 2.x版本中，DummyOperator不再支持从airflow.operators顶层直接导入，需从对应子模块引入：

修改导入语句为：

from airflow import DAG
from airflow.operators.dummy import DummyOperator

另外，Airflow 2.x里DummyOperator是EmptyOperator的别名，也可以直接使用后者：

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

内容的提问来源于stack exchange，提问作者Manish