alikia2x/cvsa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add: log for scheduleCleanupWorker

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-03-24 23:37:46 +08:00
parent fa058b22fe
commit d8b47f8fc8
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
lib/mq/exec/snapshotTick.ts
View File

@ -271,6 +271,7 @@ export const scheduleCleanupWorker = async (_job: Job) => {
const type = row.type; const type = row.type;
await setSnapshotStatus(client, id, "timeout"); await setSnapshotStatus(client, id, "timeout");
await scheduleSnapshot(client, aid, type, Date.now() + 10 * SECOND); await scheduleSnapshot(client, aid, type, Date.now() + 10 * SECOND);
logger.log(`Schedule ${id} has no response received for 5 minutes, rescheduled.`, "mq", "fn:scheduleCleanupWorker")
} }
} catch (e) { } catch (e) {
logger.error(e as Error, "mq", "fn:scheduleCleanupWorker"); logger.error(e as Error, "mq", "fn:scheduleCleanupWorker");