我正在尝试使用kedro来运行工作流。下图是我的工作流程(节点1-3是顺序的,节点31、32和33是节点3的三个分支)。您可以看到kedro是按从1到3的顺序运行的,这是由于节点之间明显的依赖关系。然而,当涉及到31,32和33个节点时,kedro实际上是随机运行的。它可以从31、32或33开始。谁知道我可以让kedro先跑31,然后跑32,再跑33?谢谢!

我已经尝试标记所有节点,但是当kedro进入节点31到33时,运行顺序是随机保持的
发布于 2021-09-10 07:44:25
因此,Kedro在运行时对节点进行拓扑排序,您不能保证获得相同的运行顺序。
人们通常尝试解决此问题的方法是将管道拆分成子管道,并通过CLI调用它们。
kedro run --pipeline a && kedro run --pipeline b
另一种选择是创建一个虚拟数据集依赖项,强制节点按照您希望的顺序运行。
https://stackoverflow.com/questions/69126849
复制相似问题