From 314beb54b5c0fa20e890e851063e6b94b96206dd Mon Sep 17 00:00:00 2001
From: alikia2x <alikia2x@outlook.com>
Date: Mon, 24 Mar 2025 23:39:29 +0800
Subject: [PATCH] add: upsertJob for scheduleCleanup

---
 lib/mq/init.ts | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/lib/mq/init.ts b/lib/mq/init.ts
index b149e76..e416988 100644
--- a/lib/mq/init.ts
+++ b/lib/mq/init.ts
@@ -45,7 +45,10 @@ export async function initMQ() {
 			immediately: true,
 		});
 
-		await SnapshotQueue.removeJobScheduler("scheduleSnapshotTick");
+		await SnapshotQueue.upsertJobScheduler("scheduleCleanup", {
+			every: 30 * MINUTE,
+			immediately: true,
+		});
 
 		logger.log("Message queue initialized.");
 	} finally {