Celery 什么时候会开始一个新的工人？

Question

我有一项任务要交给databases query。早些时候，worker2 已从我们的系统中记录下来。大约 30 分钟后，worker1 被记录在同一任务中，很像 restarting the job，它破坏了我的 sql 查询。我的问题是

• 如果worker2 失败则启动worker1 ?
• 如果worker1 启动并失败worker2 ？

从我的代码中，我没有设置任何时间限制？提前感谢您的任何想法。

我正在使用 job = chain(single_job)，但我只有一个 single_job job() 开始工作。

-更新：

我已经解决了这个问题，如果你有同样的问题，你可以在下面做。

请检查visibility timeout 以获取您的celery

请检查升级版本。

请取消sql查询的重试，有时sql查询不需要message queue。

Answer 1

大约有 18 种不同的情况会导致您所描述的情况。最常见的三种：

1. 有人安排您的作业按照两次都发生的时间表运行
2. 某人/某事启动了您任务的另一个实例
3. 任务调用在某处失败，引发了大约 30 分钟后运行的重试。