让整个芹菜链优先于新任务

Question

我想启动一系列 Celery 任务，并在任何新到达的任务之前将它们全部执行。我将有一个工作进程处理所有任务。

我想最简单的办法是根本不让它们成为链，而是启动一个同步调用一系列函数的任务。但我想利用 Celery 重试，允许每个任务重试不同的次数。

最好的方法是什么？

Answer 1

如果你有一个工人运行一个进程，那么据我所知，从使用芹菜（这没有明确记录）中可以看出，你应该得到你想要的行为。

如果要使用多个工作进程，则可能需要将CELERYD_PREFETCH_MULTIPLIER设置为 1。