Как запустить задачу celery django?

Question

[Михаил]

Суть такова. Задание нужно запускать из вьюхи, например человек нажал отправить.
В замом таске проходит некая проверка, если прошла, то нужно завершить задание, если нет, то повторить через 30 минут.
Пользователи могут запустить несколько таких задач, каждая будет делать проверку для определенного пользователя.
В самой задаче к примеру проверяется добавил ли пользователь который начал задание, комментарий к статье.
Как это сделать?
Или подскажите где почитать.

Answer 1

[Павел]

А, собственно, проблема возникла конкретно в чём?

docs.celeryproject.org/en/latest/userguide/tasks.h...

Comments

[Михаил]

Уже установлен и настроен celry, но не мной.
Что бы задание начало выполняться нужно перезапустить воркер или весь celery?

@app.task(bind=True)
def send_twitter_status(self, oauth, tweet):
    try:
        twitter = Twitter(oauth)
        twitter.update_status(tweet)
    except как тут сделать свое исключение? as exc:
        raise self.retry(exc=exc)

[Павел]

Михаил, весь celery, который захватил. Он инициализировал задачи той редакцией функции, которая была при его запуске.

Своё исключение

class MyException(Exception):
     pass

try:
    func() # бросает MyException
except MyException as exc:
    raise self.retry(exc=exc)