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()
 			}