У меня проблемы с повторением задач, вот как выглядит тестовая задача
from celery.decorators import task
@task()
def add(x, y):
if not x or not y:
raise Exception("test error")
return x+y
Я не могу найти какую-либо документацию о том, как повторить попытку декорированных задач, все, что я нашел, было следующее:
self.retry(x,y, exc=exception, countdown=30)
, который, похоже, не работает с моим случаем, поскольку переменная self
не передается из метод.
Я пытаюсь выполнить следующее, но безрезультатно:
from celery.decorators import task
@task()
def add(x, y):
if not x or not y:
try:
raise Exception("test error")
except Exception, e:
add.retry([x, y], exc=e, countdown=30)
return x+y
Я получаю следующую ошибку:
TypeError («аргумент kwargs для повторных попыток не может быть пустым. Задача должна принять * * kwargs, см. http://bit.ly/cAx3Bg ",)