correctly checking ItemsCount

Signed-off-by: Daniel Rammer <[email protected]>
flyteorg · Dec 4, 2024 · 6893c63 · 6893c63
1 parent c0acaa9
commit 6893c63
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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
 		}