diff --git a/flytepropeller/pkg/controller/nodes/subworkflow/subworkflow.go b/flytepropeller/pkg/controller/nodes/subworkflow/subworkflow.go index d70bf85438..3e688e60dd 100644 --- 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 {