From 109bfe71e1b333c38f297aece0220a92024dfbad Mon Sep 17 00:00:00 2001 From: Dan Rammer Date: Fri, 7 Apr 2023 17:12:26 -0500 Subject: [PATCH] returning 'Undefined' when recovering a SKIPPED node so that the node is executed (#551) Signed-off-by: Daniel Rammer --- flytepropeller/pkg/controller/nodes/executor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flytepropeller/pkg/controller/nodes/executor.go b/flytepropeller/pkg/controller/nodes/executor.go index 3d0707469..c447b779c 100644 --- a/flytepropeller/pkg/controller/nodes/executor.go +++ b/flytepropeller/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: