From 93bdddc21ee1e8db5f9f227bc0d30d339598c8ec Mon Sep 17 00:00:00 2001
From: alikia2x <alikia2x@outlook.com>
Date: Sat, 15 Mar 2025 16:51:07 +0800
Subject: [PATCH] fix: unexpectedly commented code to upsert jobs

---
 lib/mq/init.ts | 24 ++++++++++++------------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/lib/mq/init.ts b/lib/mq/init.ts
index df9c94d..95693ab 100644
--- a/lib/mq/init.ts
+++ b/lib/mq/init.ts
@@ -3,18 +3,18 @@ import { ClassifyVideoQueue, LatestVideosQueue, SnapshotQueue } from "lib/mq/ind
 import logger from "lib/log/logger.ts";
 
 export async function initMQ() {
-	// await LatestVideosQueue.upsertJobScheduler("getLatestVideos", {
-	// 	every: 1 * MINUTE,
-	// 	immediately: true,
-	// });
-	// await ClassifyVideoQueue.upsertJobScheduler("classifyVideos", {
-	// 	every: 5 * MINUTE,
-	// 	immediately: true,
-	// });
-	// await LatestVideosQueue.upsertJobScheduler("collectSongs", {
-	// 	every: 3 * MINUTE,
-	// 	immediately: true,
-	// });
+	await LatestVideosQueue.upsertJobScheduler("getLatestVideos", {
+		every: 1 * MINUTE,
+		immediately: true,
+	});
+	await ClassifyVideoQueue.upsertJobScheduler("classifyVideos", {
+		every: 5 * MINUTE,
+		immediately: true,
+	});
+	await LatestVideosQueue.upsertJobScheduler("collectSongs", {
+		every: 3 * MINUTE,
+		immediately: true,
+	});
 	await SnapshotQueue.upsertJobScheduler("scheduleSnapshotTick", {
 		every: 3 * MINUTE,
 		immediately: true,