我们正在用芹菜实现一个工作流程。首先我们需要并行运行一些任务,当它们都完成时,我们需要运行一个任务。
似乎我们可以使用和弦,或组和链:
chord(tasks, task)
对
group(tasks) | task
这两者的确切区别是什么?他们似乎做了同样的事。
最佳答案
Canvas docs说:
将一个组与另一个任务链接在一起将自动将其升级为一个和弦:
>>> c3 = (group(add.s(i, i) for i in xrange(10)) | xsum.s())
>>> res = c3()
>>> res.get()
90
关于python - 使用Celery Canvas,chord()和chain(group(),task)有什么区别,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/31179336/