python - 芹菜块任务从不重试

Question

有以下分块任务

update_matching_product.chunks(update_matching_products, 10).apply_async(priority=5)

当内部update_matching_product提高self.retry()分块任务时，永远不要重试。而不是那个节目 Task can be retried

如果我们打开 celery 代码，我们会看到：

  if request.called_directly:
    # raises orig stack if PyErr_Occurred,
    # and augments with exc' if that argument is defined.
    raise_with_context(exc or Retry('Task can be retried', None))  

所以问题 - 为什么直接调用 chanked 任务，以及如何重试失败的分块任务？

PS：Celery 不在 task_always_eager 模式下

标签： pythoncelery