У меня есть задача на основе класса сельдерея, определенная следующим образом:
class MyTask(Task):
name = "MY_TASK"
autoretry_for = (Exception, )
retry_kwargs = {'max_retries': 5}
retry_backoff = True
retry_backoff_max = 700
retry_jitter = False
def run(self, service, *args, **kwargs):
pass
# do something
# return some value
def on_failure(self, exc, task_id, args, kwargs, einfo):
# can extend failure method if needed
super().on_failure(exc, task_id, args, kwargs, einfo)
app.tasks.register(MyTask())
Моя задача выполняется отлично. Но когда возникает исключение, задача не повторяется
Моя версия сельдерея - 4.4.2
И python версия - 3.8.2