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

标签 python linux python-3.x celery celeryd

用一个任务文件创建的 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/

相关文章:

python - 将列表的列表转换为元组列表的列表

python - Paypal 交易 : How to receive and send funds with PayPal API and Django?

linux - 更好的解析输入的方法

python - 使用 SWIG 生成 Python 类型提示

r - 无法在 RHEL 6.7 上安装 rJava 3.3.0

linux - cmake "make install"到远程机器?

python - 初始化 MCI python 时出现问题

python - python生成器可以使用递归吗?

python - 将 Python 函数应用于多个 Pandas 列

python - Selenium 中的相对选择器?