returning 'Undefined' when recovering a SKIPPED node so that the node…

… is executed Signed-off-by: Daniel Rammer <[email protected]>
flyteorg · Apr 7, 2023 · f1ca4b6 · f1ca4b6
1 parent 986f014
commit f1ca4b6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/controller/nodes/executor.go b/pkg/controller/nodes/executor.go
@@ -216,7 +216,7 @@ func (c *nodeExecutor) attemptRecovery(ctx context.Context, nCtx handler.NodeExe
 	// A recoverable node execution should always be in a terminal phase
 	switch recovered.Closure.Phase {
 	case core.NodeExecution_SKIPPED:
-		return handler.PhaseInfoSkip(nil, "node execution recovery indicated original node was skipped"), nil
+		return handler.PhaseInfoUndefined, nil
 	case core.NodeExecution_SUCCEEDED:
 		fallthrough
 	case core.NodeExecution_RECOVERED: