Можно ли дождаться окончания группы сельдерея?

Question

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

@shared_task(name="print")
def print_order():
    print("PRINT #1")
    mylist = [(1, 2), (4, 6), (1, 4)]
    group([(add.s(*i) | order_id_print.s()) for i in mylist]).delay()


@shared_task(name="print.add")
def add(x,y):
    print("ADD #2")
    chain(add_task1.s(x, y, 'task id') | add_task2.si(x, y, "task_id")).delay()
    return x+y

@shared_task(name="add_task_1")
def add_task1(order_id, ftype, task_id):
    print("ADD task #2-1")
    print("add tasks task1 order_id {} {} {}".format(order_id, ftype, task_id))

@shared_task(name="add_task_2")
def add_task2(order_id, ftype, task_id):
    print("ADD task #2-2")
    print("add tasks task2 order_id {} {} {}".format(order_id, ftype, task_id))


@shared_task(name="print.order_id_print")
def order_id_print(id):
    print("ORDER #3")
    print("order id is {}".format(id))

Answer 1

То, что вы, вероятно, хотите, это аккорд вместо группы. Аккорд - это задача, которая выполняется только после того, как все задачи в группе завершены.

Посмотрите документы:

https://docs.celeryproject.org/en/latest/userguide/canvas.html#chords