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

update: return the value from the worker in BullMQ worker

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-04-07 00:35:36 +08:00
parent da1bea7f41
commit c4c9a3a440
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 10 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
packages/crawler/src/worker.ts
View File

@ -34,14 +34,11 @@ const latestVideoWorker = new Worker(
async (job: Job) => { async (job: Job) => {
switch (job.name) { switch (job.name) {
case "getLatestVideos": case "getLatestVideos":
await getLatestVideosWorker(job); return await getLatestVideosWorker(job);
break;
case "getVideoInfo": case "getVideoInfo":
await getVideoInfoWorker(job); return await getVideoInfoWorker(job);
break;
case "collectSongs": case "collectSongs":
await collectSongsWorker(job); return await collectSongsWorker(job);
break;
default: default:
break; break;
} }
@ -72,26 +69,19 @@ const snapshotWorker = new Worker(
async (job: Job) => { async (job: Job) => {
switch (job.name) { switch (job.name) {
case "snapshotVideo": case "snapshotVideo":
await takeSnapshotForVideoWorker(job); return await takeSnapshotForVideoWorker(job);
break;
case "snapshotTick": case "snapshotTick":
await snapshotTickWorker(job); return await snapshotTickWorker(job);
break;
case "collectMilestoneSnapshots": case "collectMilestoneSnapshots":
await collectMilestoneSnapshotsWorker(job); return await collectMilestoneSnapshotsWorker(job);
break;
case "dispatchRegularSnapshots": case "dispatchRegularSnapshots":
await regularSnapshotsWorker(job); return await regularSnapshotsWorker(job);
break;
case "scheduleCleanup": case "scheduleCleanup":
await scheduleCleanupWorker(job); return await scheduleCleanupWorker(job);
break;
case "bulkSnapshotVideo": case "bulkSnapshotVideo":
await takeBulkSnapshotForVideosWorker(job); return await takeBulkSnapshotForVideosWorker(job);
break;
case "bulkSnapshotTick": case "bulkSnapshotTick":
await bulkSnapshotTickWorker(job); return await bulkSnapshotTickWorker(job);
break;
default: default:
break; break;
} }