Airflow 2 - 导入错误 : cannot import name 'BashOperator' from 'airflow.operators'

升级到 Airflow 2 后，我在一些 DAG 中遇到了这个错误:

ImportError: cannot import name 'BashOperator' from 'airflow.operators'

最佳答案

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

from airflow.operators.bash import BashOperator

关于 Airflow 2 - 导入错误 : cannot import name 'BashOperator' from 'airflow.operators' ，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/65583927/

上一篇：JavaScript 算法 : find starting and ending indices of consecutively repeated chars from a string

下一篇：c - 从 C 中的 typedef 中减去一个值？

json - Airflow |设置变量

python - Airflow，我如何使用 BashOperator 通过 python name.py 运行 .py 文件

Airflow 身份验证设置失败， "AttributeError: can' t set 属性”

docker - 使用 docker-compose 运行分布式 Airflow 架构时如何将新用户添加到 docker 镜像

python - 有什么方法可以找到 DAG 中任意随机任务所花费的时间吗？

python - 在 airflow 中启动一个带有可变并行任务的 subdag

google-cloud-platform - 导入错误:Python Dataflow Job in cloud composer

python - Airflow :如何安排 dag 在工作日的第二天开始？

python - Airflow 工作器 - 连接中断 : IncompleteRead(0 bytes read)