芹菜批处理未收到芹菜信号

Question

我正在使用 celery.contrib.batches 执行一批 celery 任务。我知道它是实验性的，但仍然想尝试一下，我已经很接近了。在批量执行单个任务时，我故意发送诸如 backend.mark_as_started(request.id)、backend.mark_as_done(request.id, True) 之类的信号。但是工人没有收到信号。请注意，如果我摆脱批次并一次执行一个任务，一切正常。意思是，我的信号处理函数确实被执行了。

Answer 1

celery.contrib.Batches 确实不发送这些信号。解决方案是从 Batch 任务内部发送这些信号。