python - 为什么当我创建一个新的 worker 时，以前的 celery worker 的任务仍然存在？

Question

用一个任务文件创建的 celery worker“记住”了以前 celery worker 的任务，这些任务不在我现在使用的任务文件中。

在过去的某个时间，我使用一个名为“tasks.py”的包含任务的文件创建了一个 celery worker。

  celery -A tasks worker --loglevel=info

一切顺利。现在，继续前进，我正在尝试从名为“dwtasks.py”的不同任务文件创建一个 celery worker。

  celery -A dwtasks worker --loglevel=info

新工作程序启动时出现的初始屏幕列出了“dwtasks.py”中定义的任务以及“tasks.py”中定义的所有任务。如果“tasks.py”不可用，它也将无法创建工作人员。如果我不提及“tasks.py”，所有 future 的 celery worker 怎么可能知道这些任务？

Celery 是 v4.3.0(大黄)操作系统是 Ubuntu 16.04

Answer 1

您很可能错误配置了 Celery。检查您的配置，看看您是否使用自动发现，以及您的 celery 进口在哪里......