diff --git a/flytepropeller/pkg/controller/nodes/array/handler.go b/flytepropeller/pkg/controller/nodes/array/handler.go index 4f98e66796..b286e9ba36 100644 --- a/flytepropeller/pkg/controller/nodes/array/handler.go +++ b/flytepropeller/pkg/controller/nodes/array/handler.go @@ -390,7 +390,7 @@ func (a *arrayNodeHandler) Handle(ctx context.Context, nCtx interfaces.NodeExecu arrayNodeState.SubNodeSystemFailures.SetItem(index, uint64(subNodeStatus.GetSystemFailures())) indexUint := uint(index) // #nosec G115 - if arrayNodeState.SubNodeDeltaTimestamps.ItemsCount >= indexUint { + if arrayNodeState.SubNodeDeltaTimestamps.ItemsCount > indexUint { startedAt := nCtx.NodeStatus().GetLastAttemptStartedAt() subNodeStartedAt := subNodeStatus.GetLastAttemptStartedAt() if subNodeStartedAt == nil { @@ -794,7 +794,7 @@ func (a *arrayNodeHandler) buildArrayNodeContext(ctx context.Context, nCtx inter // compute start time for subNode using delta timestamp from ArrayNode NodeStatus var startedAt *metav1.Time subNodeIndexUint := uint(subNodeIndex) // #nosec G115 - if arrayNodeState.SubNodeDeltaTimestamps.ItemsCount >= subNodeIndexUint { + if arrayNodeState.SubNodeDeltaTimestamps.ItemsCount > subNodeIndexUint { if deltaSeconds := arrayNodeState.SubNodeDeltaTimestamps.GetItem(subNodeIndex); deltaSeconds != 0 { startedAt = &metav1.Time{Time: nCtx.NodeStatus().GetLastAttemptStartedAt().Add(time.Duration(deltaSeconds) * time.Second)} // #nosec G115 }