django - Django Celery - 重试后如何执行功能

Question

我在我的任务on_failure中添加了一些代码来删除一个对象。我的意图是在最大重试次数发生后删除对象，但on_failure每次方法失败时调用一次run，而不是在所有重试失败后调用。是否有其他地方可以放置这种功能（例如，def after_exhaustion(...)）。

Answer 1

任务上下文有一个重试字段，它是任务已重试的次数。您可以使用它来确定何时删除您的对象。