Выполнение задач Celery с граф зависимостей

Я хотел бы иметь задачи Celery, которые зависят от результата 2 или более других задач. Я изучил Python + Celery: объединение заданий? и http://pypi.python.org/pypi/celery-tasktree , но они хороши только в том случае, если задачи имеют только одну зависимая задача.

Я знаю о TaskSet, но, похоже, нет способа мгновенно выполнить обратный вызов, когда TaskSetResult.ready () становится True. Что я имею в виду прямо сейчас, так это иметь периодическую задачу, которая опрашивает TaskSetResult.ready () каждые несколько [милли] секунд или около того и запускает обратный вызов, когда он возвращает True, но для меня это звучит довольно неэлегантно.

Любые предложения ?

9
задан Community 23 May 2017 в 12:18
поделиться