From d98e24b62f0361e4fb2ff1e6d082c5d7481c1962 Mon Sep 17 00:00:00 2001
From: alikia2x <alikia2x@outlook.com>
Date: Mon, 7 Apr 2025 00:36:44 +0800
Subject: [PATCH] fix: incorrect return from snapshotTickWorker

---
 packages/crawler/mq/exec/snapshotTick.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/packages/crawler/mq/exec/snapshotTick.ts b/packages/crawler/mq/exec/snapshotTick.ts
index 215dd70..db7f64f 100644
--- a/packages/crawler/mq/exec/snapshotTick.ts
+++ b/packages/crawler/mq/exec/snapshotTick.ts
@@ -75,7 +75,7 @@ export const snapshotTickWorker = async (_job: Job) => {
 		const schedules = await getSnapshotsInNextSecond(client);
 		for (const schedule of schedules) {
 			if (await videoHasProcessingSchedule(client, Number(schedule.aid))) {
-				return `ALREADY_PROCESSING`;
+				continue;
 			}
 			let priority = 3;
 			if (schedule.type && priorityMap[schedule.type]) {
@@ -88,8 +88,8 @@ export const snapshotTickWorker = async (_job: Job) => {
 				id: Number(schedule.id),
 				type: schedule.type ?? "normal",
 			}, { priority });
-			return `OK`;
 		}
+		return `OK`;
 	} catch (e) {
 		logger.error(e as Error);
 	} finally {