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

… is executed (flyteorg#551) Signed-off-by: Daniel Rammer <[email protected]>
eapolinario · Apr 7, 2023 · 7abdcd7 · 7abdcd7
1 parent 986f014
commit 7abdcd7
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: