每次我开始airflow worker我都会收到此错误
[2017-11-07 16:24:12,354: ERROR/MainProcess] consumer: Cannot connect to amqp://myuser:**@127.0.0.1:8793/myvhost: timed out.
Trying again in 26.00 seconds...
我已经按照说明在Airflow上安装CeleryExecutors，以及使用本文档安装RabbitMQ。
我已经通过更改celery_result_backend和broker_url来配置我的airflow.cfg以反映这一点（例如，amqp://myuser:mypassword@localhost:8793/myvhost文档中）。我在某个时候以及更改 DAG 目录时启动并运行了它。更改 DAG 目录除了更改 DagBag 内的内容外，不应对其产生影响。
还有什么我应该看的来调试和让芹菜工人启动和运行吗？
关注这里和这里的帖子，这是因为我正在运行 Celery4.1.0。我降级到 Celery3.1.7，它现在可以工作了。