add: set scheduled job status to 'processing' before adding to bullmq

2025-03-25 05:05:33 +08:00 · 2025-03-25 05:05:33 +08:00 · 86337e3802
commit 86337e3802
parent 76c9256662
1 changed files with 1 additions and 0 deletions
--- a/lib/mq/exec/snapshotTick.ts
+++ b/lib/mq/exec/snapshotTick.ts
@ -44,6 +44,7 @@ export const snapshotTickWorker = async (_job: Job) => {
 				priority = priorityMap[schedule.type];
 			}
 			const aid = Number(schedule.aid);
+			await setSnapshotStatus(client, schedule.id, "processing");
 			await SnapshotQueue.add("snapshotVideo", {
 				aid: aid,
 				id: Number(schedule.id),