我想在芹菜链命令中使用块。
chain = task1.s(arg1) | task2.chunks(?,CHUNK_SIZE) | task3.chunks(?, CHUNK_SIZE)
基本上我想做的是运行task1,将它的结果分块并将块发送到task2,然后它应该调用task3,task3也应该从task2接收分块结果以完成该过程。为什么?因为 task1 和 task2 都可以返回相当数量的我想分批处理的项目。
上面的代码不起作用,因为我不太确定要放什么而不是问号才能使它起作用。
我不太确定这是否可行,因为搜索并没有提供太多结果,因此在无法构建这样的工作流程的情况下,我会对合理的替代方案感兴趣。