用一个任务文件创建的 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
最佳答案
您很可能错误配置了 Celery。检查您的配置,看看您是否使用自动发现,以及您的 celery 进口在哪里......
关于python - 为什么当我创建一个新的 worker 时,以前的 celery worker 的任务仍然存在?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57009569/