diff --git a/packages/crawler/mq/init.ts b/packages/crawler/mq/init.ts
index 845f064..fb94ed8 100644
--- a/packages/crawler/mq/init.ts
+++ b/packages/crawler/mq/init.ts
@@ -8,68 +8,68 @@ import { sql } from "@core/db/dbNew";
 export async function initMQ() {
 	await initSnapshotWindowCounts(sql, redis);
 
-	// await LatestVideosQueue.upsertJobScheduler("getLatestVideos", {
-	// 	every: 1 * 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 LatestVideosQueue.upsertJobScheduler("collectSongs", {
+		every: 3 * MINUTE,
+		immediately: true
+	});
 
-	// await SnapshotQueue.upsertJobScheduler(
-	// 	"snapshotTick",
-	// 	{
-	// 		every: 1 * SECOND,
-	// 		immediately: true
-	// 	},
-	// 	{
-	// 		opts: {
-	// 			removeOnComplete: 300,
-	// 			removeOnFail: 600
-	// 		}
-	// 	}
-	// );
+	await SnapshotQueue.upsertJobScheduler(
+		"snapshotTick",
+		{
+			every: 1 * SECOND,
+			immediately: true
+		},
+		{
+			opts: {
+				removeOnComplete: 300,
+				removeOnFail: 600
+			}
+		}
+	);
 
-	// await SnapshotQueue.upsertJobScheduler(
-	// 	"bulkSnapshotTick",
-	// 	{
-	// 		every: 15 * SECOND,
-	// 		immediately: true
-	// 	},
-	// 	{
-	// 		opts: {
-	// 			removeOnComplete: 60,
-	// 			removeOnFail: 600
-	// 		}
-	// 	}
-	// );
+	await SnapshotQueue.upsertJobScheduler(
+		"bulkSnapshotTick",
+		{
+			every: 15 * SECOND,
+			immediately: true
+		},
+		{
+			opts: {
+				removeOnComplete: 60,
+				removeOnFail: 600
+			}
+		}
+	);
 
-	// await SnapshotQueue.upsertJobScheduler("dispatchMilestoneSnapshots", {
-	// 	every: 5 * MINUTE,
-	// 	immediately: true
-	// });
+	await SnapshotQueue.upsertJobScheduler("dispatchMilestoneSnapshots", {
+		every: 5 * MINUTE,
+		immediately: true
+	});
 
-	// await SnapshotQueue.upsertJobScheduler("dispatchRegularSnapshots", {
-	// 	every: 30 * MINUTE,
-	// 	immediately: true
-	// });
+	await SnapshotQueue.upsertJobScheduler("dispatchRegularSnapshots", {
+		every: 30 * MINUTE,
+		immediately: true
+	});
 
-	// await SnapshotQueue.upsertJobScheduler("dispatchArchiveSnapshots", {
-	// 	every: 2 * HOUR,
-	// 	immediately: false
-	// });
+	await SnapshotQueue.upsertJobScheduler("dispatchArchiveSnapshots", {
+		every: 2 * HOUR,
+		immediately: false
+	});
 
-	// await SnapshotQueue.upsertJobScheduler("scheduleCleanup", {
-	// 	every: 2 * MINUTE,
-	// 	immediately: true
-	// });
+	await SnapshotQueue.upsertJobScheduler("scheduleCleanup", {
+		every: 2 * MINUTE,
+		immediately: true
+	});
 
 	logger.log("Message queue initialized.");
 }