升级到 Airflow 2 后，我在某些 DAG 中遇到了该错误：
ModuleNotFoundError: No module named 'airflow.operators.sensors'
我试图导入ExternalTaskSensor，我的研究引导我找到了这篇文章，结果就是这个类。
对我来说正确的导入是
from airflow.sensors.external_task import ExternalTaskSensor
仅供参考，以防将来有人遇到这种情况。
我通过更改导入解决了。
from airflow.operators.sensors import BaseSensorOperator
from airflow.sensors import BaseSensorOperator
| 归档时间： |
|
| 查看次数： |
11442 次 |
| 最近记录： |