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

Question

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

我想执行一些代码只有如果最后一次重试失败并退出函数而不引发异常。可能吗？

Answer 1

其实我在中找到了答案：

@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

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

How to execute some code at last retry of a Celery task

django

celery

background-task