Повтор выполнения задач с помощью Django-Celery - Django / Celery

У меня проблемы с повторением задач, вот как выглядит тестовая задача

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 ",)

20
задан Cœur 17 October 2018 в 02:08
поделиться