Elizhium/litlyx
1
0
Fork 0
mirror of https://github.com/Litlyx/litlyx synced 2025-12-10 07:48:37 +01:00
Code Issues Packages Projects Releases Wiki Activity

better processed logs

Browse Source
This commit is contained in:
Emily
2024-09-17 13:39:56 +02:00
parent e813b3246d
commit db32afe741
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
shared/services/RedisStreamService.ts
View File

@@ -50,8 +50,10 @@ export class RedisStreamService {
static async startReadingLoop(options: ReadingLoopOptions, processFunction: (content: Record<string, string>) => Promise<any>) { static async startReadingLoop(options: ReadingLoopOptions, processFunction: (content: Record<string, string>) => Promise<any>) {
setInterval(() => { setInterval(() => {
console.log('Processed:', (RedisStreamService.processed / 30).toFixed(), '/s'); if (RedisStreamService.processed > 0) {
RedisStreamService.processed = 0; console.log('Processed:', (RedisStreamService.processed / 30).toFixed(2), '/s');
RedisStreamService.processed = 0;
}
}, 30_000) }, 30_000)
try { try {