django - Celery - 有没有办法在中间的子任务失败后继续执行链

Question

我需要找到在任何中间子任务抛出异常后如何使用 immutable=True 子任务继续执行链的方式。

我已经读过这个 thread而这个 issue comment .现在这些错误已修复，但我需要实现相反的行为。我不需要停止我的链执行。可能还有另一个以任何顺序依次执行独立任务列表而不在它们之间发送结果的方法 ?我需要异步执行它们，因为在这种情况下 django-celery 将存储关于每个任务的统计信息。

一种解决方案是用以下内容覆盖所有子任务的主体:

try:
    ...
except Exception, e:
    logger.error('Exception raised: %s' % e)
    raise e

但在这种情况下，所有子任务都将使用 执行。成功 django-celery 管理界面中的异常状态和追溯将毫无用处。

Answer 1

Perharps 使用和弦和 CELERY_CHORD_PROPAGATES

因此，当 Chord 的一个子部分出现故障时，您可以管理异常并对其执行所需的操作(记录某些内容、重新排队任务以进行更改等)。

由于您已经拥有一个链，Chord 将只是其中的一部分，您需要了解状态的任务。