Сельдерей цепочка групп - PullRequest
0 голосов
/ 12 мая 2018

Я новичок в сельдерее. Я хотел бы объединить две группы задач, где все задачи в группе выполняются асинхронно, а вторая группа обрабатывается только после того, как все задачи в первой группе выполнены. Мне не нужно возвращать результаты ни для одной из задач.

Я пытался

g1 = group([task1.si(1), tasks1.si(2)])
g2 = group([task2.si(3), tasks2.si(4)])
chain(g1,g2).delay()

и похоже, что вторая группа начинает обрабатывать (task2.si (3)) после выполнения первой задачи в первой группе (task1.si (1)). Я ожидаю, что task2.si (3) запустится после того, как tasks1.si (2) будет завершено.

Как связать две группы так, чтобы вторая группа начала обрабатываться только после завершения первой группы?

Спасибо!

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...