python - 使用 Celery Canvas，chord() 和 chain(group(), task) 有什么区别

Question

我们正在使用 Celery 实现工作流程。首先，我们需要并行运行一些任务，当它们全部完成后，我们需要运行一个任务。

看来我们可以使用和弦，或者组和链:

chord(tasks, task)

对比

group(tasks) | task

这两者之间的确切区别是什么？他们似乎在做同样的事情。

Answer 1

Canvas docs说:

Chaining a group together with another task will automatically upgrade it to be a chord:

 >>> c3 = (group(add.s(i, i) for i in xrange(10)) | xsum.s())
>>> res = c3()
>>> res.get()
90