From 09c1aae4143990f9cda2fbcfc3696cbfce811381 Mon Sep 17 00:00:00 2001
From: Drew Sirenko <68304519+AndrewSirenko@users.noreply.github.com>
Date: Wed, 1 May 2024 18:03:26 +0000
Subject: [PATCH] Test batcher change

---
 pkg/batcher/batcher.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/batcher/batcher.go b/pkg/batcher/batcher.go
index 0bfa703e87..1795325293 100644
--- 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()
 			}