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

fix: unexpectedly commented code to upsert jobs

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-03-15 16:51:07 +08:00
parent afffbd8ecb
commit 93bdddc21e
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
lib/mq/init.ts
View File

@ -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,