diff --git a/backend/src/v2/driver/driver.go b/backend/src/v2/driver/driver.go index f916b4f058d..f38be9a73a9 100644 --- a/backend/src/v2/driver/driver.go +++ b/backend/src/v2/driver/driver.go @@ -1267,6 +1267,7 @@ func resolveInputs(ctx context.Context, dag *metadata.DAG, iterationIndex *int, } else { // The producer subtask is not a DAG, so we exit the loop. producerSubTaskMaybeDAG = false + inputs.ParameterValues[name] = producerOutputs[taskOutput.GetOutputParameterKey()] } }