问题描述
我使用 Django 和 Celery 来运行我的后台任务。我有一项可能因某些 IO 原因而失败的任务:
@shared_task(bind=True)
def mytask(self,someargs):
try:
do_some_io_operation()
except SomeException as e:
self.retry(max_retries=5)
# do some other stuff
我想仅在最后一次重试失败时执行一些代码并退出函数而不引发异常。 可能吗?
解决方法
我实际上在another ticket中找到了答案:
@shared_task(bind=True)
def mytask(self,someargs):
max_retries = 5
try:
do_some_io_operation()
except SomeException as e:
if (self.request.retries >= max_retries):
# do some stuff
return
self.retry(max_retries=max_retries)
# do some other stuff