python - 芹菜 - 倒计时如何工作？

Question

我想了解提供 countdown=xx 如何影响任务的调度。根据http://docs.celeryproject.org/en/latest/userguide/calling.html?highlight=countdown#eta-and-countdown，设置倒计时意味着任务至少需要 xx 秒才能执行。

我想知道的是它是如何实现的。当我们提供一个带有倒计时值的任务时，该任务是添加到队列中但没有工作人员拿起它，还是工作人员拿起任务但推迟执行，直到至少倒计时值到期？

Answer 1

任务由工作人员选择，但未确认。

这意味着如果电源耗尽，稍后将由不同的工作人员重新获取任务。

任务的 args/kwargs 会一直保存在 worker 的内存中，直到完成，所以请记住这一点，因为有很多倒计时任务和大型 args/kwargs 可能会很快用完。