即使在 pip 安装气流后也没有定义"芹菜执行器"[芹菜]

Question

我试图在本地计算机上从Localexecutor切换到CeleryExecutor。我应该使用pip install airflow[celery]安装必要的库。我还安装了Redis并运行。

但是，当我尝试运行airflow worker时，我会得到错误：

DEFAULT_EXECUTOR = CeleryExecutor()
NameError:  CeleryExecutor' is not defined

我的broker url和celery_result_backend都设置为redis://localhost:6379，而REDIS在后台运行。我在做什么错？

Answer 1

似乎您切换了，但是气流不知道。在运行每个气流命令之前，请检查您是否已指定 airflow_home env变量，并且您没有文件夹〜/airflow 和file 〜/airflow.cfg 在您的主目录中！）将其用作默认值（忽略您的 airflow_home ）。

有关此问题的更多详细信息：https：//github.com/puckel/docker-airflow/issues/132

Answer 2

打开python shell并运行from celery import Celery以测试是否已经安装了celery。如果不是，您可以通过PIP安装它。 pip install celery

Answer 3

尝试打开安装气流的python外壳并运行以下操作：

>>> from airflow.executors.celery_executor import CeleryExecutor

我认为您会遇到更有用的错误。