В Celery, как мне запустить задачу, а затем заставить эту задачу выполнить другую задачу и поддерживать ее работу?

Question

#tasks.py
from celery.task import Task
class Randomer(Task):
    def run(self, **kwargs):
        #run Randomer again!!!
        return random.randrange(0,1000000)


>>> from tasks import Randomer
>>> r = Randomer()
>>> r.delay()

Прямо сейчас я запускаю простую задачу. И это возвращает случайное число. Но как мне заставить его выполнить другую задачу, внутри этой задачи ?

Answer 1

Вы можете позвонить other_task.delay() изнутри Randomer.run;в этом случае вы можете установить Randomer.ignore_result = True (и other_task.ignore_result, и т. д.).

Помните, что задания сельдерея delay возвращаются мгновенно, поэтому, если вы не установили лимит или время ожиданияна вложенных вызовах (или рекурсивных вызовах) вы можете довольно быстро достичь расплавления.

Вместо рекурсивных или вложенных задач вы должны рассмотреть бесконечный цикл, чтобы избежать переполнения стека (без каламбура).

from celery.task import Task
class Randomer(Task):
    def run(self, **kwargs):
        while True:
           do_something(**kwargs)
           time.sleep(600)

Answer 2

Вы можете объединить подзадачи, как описано здесь: http://docs.celeryproject.org/en/latest/userguide/canvas.html#chains