diff --git a/shared/services/RedisStreamService.ts b/shared/services/RedisStreamService.ts index 11013d4..47f7cb2 100644 --- a/shared/services/RedisStreamService.ts +++ b/shared/services/RedisStreamService.ts @@ -50,8 +50,10 @@ export class RedisStreamService { static async startReadingLoop(options: ReadingLoopOptions, processFunction: (content: Record) => Promise) { setInterval(() => { - console.log('Processed:', (RedisStreamService.processed / 30).toFixed(), '/s'); - RedisStreamService.processed = 0; + if (RedisStreamService.processed > 0) { + console.log('Processed:', (RedisStreamService.processed / 30).toFixed(2), '/s'); + RedisStreamService.processed = 0; + } }, 30_000) try {