Airflow 2 - 导入错误:无法从“airflow.operators”导入名称“BashOperator”

And*_*dor 3 airflow

升级到 Airflow 2 后,我在某些 DAG 中遇到了该错误:

ImportError: cannot import name 'BashOperator' from 'airflow.operators'
Run Code Online (Sandbox Code Playgroud)

小智 9

我最近遇到了同样的问题。以下对我有用:

from airflow.operators.bash import BashOperator
Run Code Online (Sandbox Code Playgroud)