我想了解提供 countdown=xx 如何影响任务的调度。根据http://docs.celeryproject.org/en/latest/userguide/calling.html?highlight=countdown#eta-and-countdown , 设置倒计时意味着任务至少需要 xx 秒来执行。
我想知道的是它是如何实现的。当我们为任务提供倒计时值时,任务是否已添加到队列中但没有工作人员接收它,或者工作人员接收了任务但推迟了它的执行,直到至少倒计时值到期?
最佳答案
任务由工作人员选择,但未确认。
这意味着如果电量耗尽,稍后将由不同的工作人员重新获取任务。
任务的 args/kwargs 会保存在 worker 的内存中,直到它完成,所以请记住这一点,因为你可能会很快用完大量倒计时任务和大的 args/kwargs。
关于python - celery - 倒计时如何工作?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/18977300/