从芹菜批处理中收不到芹菜信号

Question

我正在使用celery.contrib.batches执行一批芹菜任务。我知道它的实验，但仍然想尝试，我非常接近。在批处理中执行单个任务时，我会故意发送像backend.mark_as_started（request.id），backend.mark_as_done（request.id，True）的信号。但这些信号并没有在工作人员那里收到。请注意，如果我一次摆脱批次并执行任务，则一切正常。意思是，我的信号处理函数确实得到执行。

Answer 1

celery.contrib.Batches确实不会发送这些信号。解决方案是从批处理任务中发送这些信号。