alikia2x/cvsa
1
0
Fork 0
Code

fix: unexpectly commented MQ init code

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-10-29 21:46:23 +08:00
parent 937482e50b
commit e71c2f140b
1 changed files with 50 additions and 50 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

100
packages/crawler/mq/init.ts
View File

@ -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.");
}