首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >可以等到芹菜组结束吗?

可以等到芹菜组结束吗?
EN

Stack Overflow用户
提问于 2019-04-11 15:19:28
回答 1查看 2.1K关注 0票数 4

我正在尝试完成组任务,并等待所有组子任务完成,然后运行最后一个任务。但是当我调用task时,它调用group和last task,但最后一个任务在group结束之前完成。可以等到组内的所有任务都完成吗?

代码语言:javascript
运行
复制
@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))
EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2019-04-11 15:52:22

你可能想要的是一个和弦而不是一个组合。chord是仅在组中的所有任务都执行完毕后才执行的任务。

请看一下文档:

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

票数 3
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/55626750

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档