kubeflow管道动态输出列表作为输入参数

Question

一个动态列表。我想收集循环中的所有输出，并将它们传递给另一个ContainerOp。
下面这样的东西显然行不通，因为outputs列表是静态的。在

with dsl.ParallelFor(op1.output) as item:
    op2 = dsl.ContainerOp(
      name='op2',
      ...
      file_outputs={
         'outputs': '/outputs.json',
    })
    outputs.append(op2.output)


op3 = dsl.ContainerOp(
   name='op3',
   ...
   arguments=['--input': outputs]  # won't work
)

Answer 1

问题是op3没有正确地引用op2的输出作为输入参数。试试这个：

op3 = dsl.ContainerOp(
    ...
    arguments=[' input': op2.outputs['outputs']]
)