From a3f39b95d246b1ad7328c91441c89beb039bee62 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= <lindesvard@gmail.com>
Date: Thu, 30 Jan 2025 22:32:04 +0000
Subject: [PATCH] fix(buffer): tmp lower inserts

---
 packages/db/src/buffers/event-buffer.ts | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/packages/db/src/buffers/event-buffer.ts b/packages/db/src/buffers/event-buffer.ts
index d9e5346e..31fc9031 100644
--- a/packages/db/src/buffers/event-buffer.ts
+++ b/packages/db/src/buffers/event-buffer.ts
@@ -231,12 +231,13 @@ export class EventBuffer extends RedisBuffer<BufferType> {
   }
 
   protected async insertIntoDB(items: BufferType[]): Promise<void> {
-    for (const chunk of this.getChunks(items, 1500)) {
+    for (const chunk of this.getChunks(items, 500)) {
       await ch.insert({
         table: TABLE_NAMES.events,
         values: chunk,
         format: 'JSONEachRow',
       });
+      await new Promise((resolve) => setTimeout(resolve, 50));
     }
   }