因kombu更新导致Airflow Worker崩溃：async属性错误求助

我之前维护puckel部署的Airflow 1.9.0 Docker环境时，碰到过完全一样的错误！这个问题的核心是Kombu版本与Airflow 1.9.0依赖的Celery版本不兼容。

错误原因分析 #

Airflow 1.9.0依赖的Celery版本偏老，它会尝试访问Kombu的async属性，但在较新的Kombu版本中，这个属性被移除或重命名了，直接导致Worker启动时抛出AttributeError: async。

具体解决步骤 #

• 先检查当前容器内安装的Kombu版本：

  docker exec -it <你的Airflow Worker容器名> pip show kombu
  

• 安装与Airflow 1.9.0兼容的Kombu版本（亲测4.3.0版本可以完美适配）：

  docker exec -it <你的Airflow Worker容器名> pip install kombu==4.3.0
  

• 为了避免后续重启容器后问题复发，建议修改puckel的Airflow Docker配置：
  • 如果使用自定义requirements.txt，添加一行：kombu==4.3.0
  • 或者修改Dockerfile，在安装Airflow之后加上RUN pip install kombu==4.3.0

完成以上操作后，重新启动Airflow Worker，应该就能正常运行了。

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