如何在最后一次重试 Celery 任务时执行一些代码

如何解决如何在最后一次重试 Celery 任务时执行一些代码

我使用 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