From 86337e3802ab49fe8734e2236f3c4c730f716a77 Mon Sep 17 00:00:00 2001 From: alikia2x Date: Tue, 25 Mar 2025 05:05:33 +0800 Subject: [PATCH] add: set scheduled job status to 'processing' before adding to bullmq --- lib/mq/exec/snapshotTick.ts | 1 + 1 file changed, 1 insertion(+) diff --git a/lib/mq/exec/snapshotTick.ts b/lib/mq/exec/snapshotTick.ts index 55d3f70..93f0907 100644 --- 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),