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

add: upsertJob for scheduleCleanup

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

5
lib/mq/init.ts
View File

@ -45,7 +45,10 @@ export async function initMQ() {
immediately: true, immediately: true,
}); });
await SnapshotQueue.removeJobScheduler("scheduleSnapshotTick"); await SnapshotQueue.upsertJobScheduler("scheduleCleanup", {
every: 30 * MINUTE,
immediately: true,
});
logger.log("Message queue initialized."); logger.log("Message queue initialized.");
} finally { } finally {