persist abort state on NodePhaseTimingOut

Signed-off-by: Paul Dittamo <[email protected]>
flyteorg · Jan 23, 2024 · 1172ef6 · 1172ef6
1 parent 542c4aa
commit 1172ef6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flytepropeller/pkg/controller/nodes/executor.go b/flytepropeller/pkg/controller/nodes/executor.go
@@ -1341,7 +1341,7 @@ func (c *nodeExecutor) HandleNode(ctx context.Context, dag executors.DAGStructur
 
 	if currentPhase == v1alpha1.NodePhaseTimingOut {
 		logger.Debugf(ctx, "node timing out")
-		if err := c.Abort(ctx, h, nCtx, "node timed out", false); err != nil {
+		if err := c.Abort(ctx, h, nCtx, "node timed out", true); err != nil {
 			return interfaces.NodeStatusUndefined, err
 		}