This commit is contained in:
Emily
2024-08-30 17:32:36 +02:00
parent 01e8a9ab1d
commit 748894b946

View File

@@ -26,9 +26,9 @@ export class RedisStreamService {
console.log('RedisStreamService DEV_MODE=', process.env.DEV_MODE === 'true'); console.log('RedisStreamService DEV_MODE=', process.env.DEV_MODE === 'true');
await this.client.connect(); await this.client.connect();
setInterval(() => { setInterval(() => {
console.log('Processed:', RedisStreamService.processed, '/s'); console.log('Processed:', (RedisStreamService.processed / 30).toFixed(), '/s');
RedisStreamService.processed = 0; RedisStreamService.processed = 0;
}, 1000) }, 30_000)
} }