当我有类似以下的东西
group1 = group(task1.si(), task1.si(), task1.si())
group2 = group(task2.si(), task2.si(), task2.si())
workflow = chain(group1, group2, task3.si())
直观的解释是task3应该只在第2组中的所有任务完成后执行.
实际上,任务3在group1启动但尚未完成时执行.
我究竟做错了什么？