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

user_8753169 0
Viewed 321

I am using Django with Celery to run my background tasks. I have a task that can fail for some IO reasons:

@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

I want to execute some code only if the last retry fails and exit the function without raising an exception. Is it possible?

background-task celery django
1 Answers

I actually found the answer in 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
user_87531690
Related