diff --git a/packages/db/src/buffers/bot-buffer-psql.ts b/packages/db/src/buffers/bot-buffer-psql.ts index d9d67332..0f153ece 100644 --- a/packages/db/src/buffers/bot-buffer-psql.ts +++ b/packages/db/src/buffers/bot-buffer-psql.ts @@ -39,7 +39,7 @@ export class BotBuffer extends BaseBuffer { }, }); - if (unprocessedCount >= this.batchSize) { + if (unprocessedCount >= this.batchSize && !process.env.TEST_NEW_BUFFER) { await this.tryFlush(); } } catch (error) {