Test batcher change

kubernetes-sigs · May 1, 2024 · 09c1aae · 09c1aae
1 parent 458701d
commit 09c1aae
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/batcher/batcher.go b/pkg/batcher/batcher.go
@@ -125,7 +125,7 @@ func (b *Batcher[InputType, ResultType]) taskManager() {
 				timerCh = time.After(b.maxDelay)
 			}
 
-			if len(b.pendingTasks) == b.maxEntries {
+			if len(b.pendingTasks) >= b.maxEntries {
 				klog.V(7).InfoS("taskManager: maxEntries reached")
 				exec()
 			}