【发布时间】:2018-04-22 12:35:49
【问题描述】:
我正在使用 django-celery 3.2 和 celery 3.1.25。 我添加了以下设置 -
CELERY_TASK_ACKS_LATE = True
task_reject_on_worker_lost = True
如果我将 celery 4.x 与 django-celery 3.2 一起使用,应用程序会导致以下错误并且无法加载
ImportError: 没有名为 vine.five 的模块
复制步骤
触发一些任务,并从日志中获取它们的 pid。我使用 kill 命令随机杀死一个工人(pid)。
预期行为
任务应该回到队列并由同一个或其他工作人员拾取。
实际行为
任务丢失了。
【问题讨论】: