From 3b79086fcd397b2f0b0d6ae947e58976855a40e6 Mon Sep 17 00:00:00 2001 From: Thomas Newton Date: Mon, 13 Nov 2023 21:08:29 +0000 Subject: [PATCH] `ClearSubNodeStatus` on failure --- flytepropeller/pkg/controller/nodes/executor.go | 1 + 1 file changed, 1 insertion(+) diff --git a/flytepropeller/pkg/controller/nodes/executor.go b/flytepropeller/pkg/controller/nodes/executor.go index b9d727db7e..f5bee9e97e 100644 --- a/flytepropeller/pkg/controller/nodes/executor.go +++ b/flytepropeller/pkg/controller/nodes/executor.go @@ -1320,6 +1320,7 @@ func (c *nodeExecutor) HandleNode(ctx context.Context, dag executors.DAGStructur if err := c.Abort(ctx, h, nCtx, "node failing", false); err != nil { return interfaces.NodeStatusUndefined, err } + nodeStatus.ClearSubNodeStatus() nodeStatus.UpdatePhase(v1alpha1.NodePhaseFailed, metav1.Now(), nodeStatus.GetMessage(), nodeStatus.GetExecutionError()) c.metrics.FailureDuration.Observe(ctx, nodeStatus.GetStartedAt().Time, nodeStatus.GetStoppedAt().Time) if nCtx.NodeExecutionMetadata().IsInterruptible() {