From c4c9a3a440c32013540d1b2fa4e6dd5b4284002e Mon Sep 17 00:00:00 2001 From: alikia2x Date: Mon, 7 Apr 2025 00:35:36 +0800 Subject: [PATCH] update: return the value from the worker in BullMQ worker --- packages/crawler/src/worker.ts | 30 ++++++++++-------------------- 1 file changed, 10 insertions(+), 20 deletions(-) diff --git a/packages/crawler/src/worker.ts b/packages/crawler/src/worker.ts index 6507d63..7f3015e 100644 --- a/packages/crawler/src/worker.ts +++ b/packages/crawler/src/worker.ts @@ -34,14 +34,11 @@ const latestVideoWorker = new Worker( async (job: Job) => { switch (job.name) { case "getLatestVideos": - await getLatestVideosWorker(job); - break; + return await getLatestVideosWorker(job); case "getVideoInfo": - await getVideoInfoWorker(job); - break; + return await getVideoInfoWorker(job); case "collectSongs": - await collectSongsWorker(job); - break; + return await collectSongsWorker(job); default: break; } @@ -72,26 +69,19 @@ const snapshotWorker = new Worker( async (job: Job) => { switch (job.name) { case "snapshotVideo": - await takeSnapshotForVideoWorker(job); - break; + return await takeSnapshotForVideoWorker(job); case "snapshotTick": - await snapshotTickWorker(job); - break; + return await snapshotTickWorker(job); case "collectMilestoneSnapshots": - await collectMilestoneSnapshotsWorker(job); - break; + return await collectMilestoneSnapshotsWorker(job); case "dispatchRegularSnapshots": - await regularSnapshotsWorker(job); - break; + return await regularSnapshotsWorker(job); case "scheduleCleanup": - await scheduleCleanupWorker(job); - break; + return await scheduleCleanupWorker(job); case "bulkSnapshotVideo": - await takeBulkSnapshotForVideosWorker(job); - break; + return await takeBulkSnapshotForVideosWorker(job); case "bulkSnapshotTick": - await bulkSnapshotTickWorker(job); - break; + return await bulkSnapshotTickWorker(job); default: break; }