fix recovery of already recovered workflow (#530)

Signed-off-by: Felix Ruess <[email protected]>
flyteorg · Feb 25, 2023 · 03a6672 · 03a6672
1 parent 752f55e
commit 03a6672
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/controller/nodes/executor.go b/pkg/controller/nodes/executor.go
@@ -190,6 +190,8 @@ func (c *nodeExecutor) attemptRecovery(ctx context.Context, nCtx handler.NodeExe
 	case core.NodeExecution_SKIPPED:
 		return handler.PhaseInfoSkip(nil, "node execution recovery indicated original node was skipped"), nil
 	case core.NodeExecution_SUCCEEDED:
+		fallthrough
+	case core.NodeExecution_RECOVERED:
 		logger.Debugf(ctx, "Node [%+v] can be recovered. Proceeding to copy inputs and outputs", nCtx.NodeExecutionMetadata().GetNodeExecutionID())
 	default:
 		// The node execution may be partially recoverable through intra task checkpointing. Save the checkpoint