only writting subworkflow inputs once (flyteorg#464)

Signed-off-by: Daniel Rammer <[email protected]>
eapolinario · Jul 30, 2022 · 7a920e0 · 7a920e0
1 parent 725789d
commit 7a920e0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flytepropeller/pkg/controller/nodes/subworkflow/subworkflow.go b/flytepropeller/pkg/controller/nodes/subworkflow/subworkflow.go
@@ -223,7 +223,7 @@ func (s *subworkflowHandler) CheckSubWorkflowStatus(ctx context.Context, nCtx ha
 
 	status := nCtx.NodeStatus()
 	nodeLookup := executors.NewNodeLookup(subWorkflow, status)
-	return s.startAndHandleSubWorkflow(ctx, nCtx, subWorkflow, nodeLookup)
+	return s.handleSubWorkflow(ctx, nCtx, subWorkflow, nodeLookup)
 }
 
 func (s *subworkflowHandler) HandleAbort(ctx context.Context, nCtx handler.NodeExecutionContext, reason string) error {