From 49e6b50e4dc9d36962d512eecafafcd25bd9b449 Mon Sep 17 00:00:00 2001
From: Philip O'Toole <philip.otoole@yahoo.com>
Date: Mon, 23 May 2022 10:54:45 -0400
Subject: [PATCH] Stricter queue batch logic

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

diff --git a/queue/queue.go b/queue/queue.go
index 07dda485..3cc92a45 100644
--- a/queue/queue.go
+++ b/queue/queue.go
@@ -168,7 +168,7 @@ func (q *Queue) run() {
 			if len(queuedStmts) == 1 {
 				timer.Reset(q.timeout)
 			}
-			if len(queuedStmts) >= q.batchSize {
+			if len(queuedStmts) == q.batchSize {
 				writeFn()
 			}
 		case <-timer.C: