我在任务的on_failure
中添加了一些代码,删除了一个对象。我的意图是在出现最大重试次数后删除对象,但run
方法每次失败都会调用on_failure
一次,而不是在所有重试失败后调用。是否还有其他地方可以放置这种功能(例如def after_exhaustion(...)
)。
任务上下文有一个retries字段,该字段是任务重试的次数。您可以使用它来确定何时删除对象。