From 272ea7fa7cec7cc3a91a196c4745fbaf37fdc0c1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= Date: Tue, 4 Feb 2025 12:07:21 +0100 Subject: [PATCH] fix(buffer): add correct envs --- packages/db/src/buffers/event-buffer-psql.ts | 4 ++-- packages/db/src/buffers/profile-buffer-psql.ts | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/packages/db/src/buffers/event-buffer-psql.ts b/packages/db/src/buffers/event-buffer-psql.ts index 39e967e4..d1afe2ec 100644 --- a/packages/db/src/buffers/event-buffer-psql.ts +++ b/packages/db/src/buffers/event-buffer-psql.ts @@ -14,8 +14,8 @@ export class EventBuffer extends BaseBuffer { private daysToKeep = process.env.EVENT_BUFFER_DAYS_TO_KEEP ? Number.parseInt(process.env.EVENT_BUFFER_DAYS_TO_KEEP, 10) : 3; - private batchSize = process.env.EVENT_BUFFER_CHUNK_SIZE - ? Number.parseInt(process.env.EVENT_BUFFER_CHUNK_SIZE, 10) + private batchSize = process.env.EVENT_BUFFER_BATCH_SIZE + ? Number.parseInt(process.env.EVENT_BUFFER_BATCH_SIZE, 10) : 2000; private chunkSize = process.env.EVENT_BUFFER_CHUNK_SIZE ? Number.parseInt(process.env.EVENT_BUFFER_CHUNK_SIZE, 10) diff --git a/packages/db/src/buffers/profile-buffer-psql.ts b/packages/db/src/buffers/profile-buffer-psql.ts index 7233c3c7..1883015d 100644 --- a/packages/db/src/buffers/profile-buffer-psql.ts +++ b/packages/db/src/buffers/profile-buffer-psql.ts @@ -11,8 +11,8 @@ export class ProfileBuffer extends BaseBuffer { private daysToKeep = process.env.PROFILE_BUFFER_DAYS_TO_KEEP ? Number.parseInt(process.env.PROFILE_BUFFER_DAYS_TO_KEEP, 10) : 7; - private batchSize = process.env.PROFILE_BUFFER_CHUNK_SIZE - ? Number.parseInt(process.env.PROFILE_BUFFER_CHUNK_SIZE, 10) + private batchSize = process.env.PROFILE_BUFFER_BATCH_SIZE + ? Number.parseInt(process.env.PROFILE_BUFFER_BATCH_SIZE, 10) : 2000; private chunkSize = process.env.PROFILE_BUFFER_CHUNK_SIZE ? Number.parseInt(process.env.PROFILE_BUFFER_CHUNK_SIZE, 10)