diff --git a/shared/services/RedisStreamService.ts b/shared/services/RedisStreamService.ts index f9e2f8a..ed76c0e 100644 --- a/shared/services/RedisStreamService.ts +++ b/shared/services/RedisStreamService.ts @@ -26,9 +26,9 @@ export class RedisStreamService { console.log('RedisStreamService DEV_MODE=', process.env.DEV_MODE === 'true'); await this.client.connect(); setInterval(() => { - console.log('Processed:', RedisStreamService.processed, '/s'); + console.log('Processed:', (RedisStreamService.processed / 30).toFixed(), '/s'); RedisStreamService.processed = 0; - }, 1000) + }, 30_000) }