From 6df6345ec19c6a59e0d1d381255ef41a05dea6f8 Mon Sep 17 00:00:00 2001 From: alikia2x Date: Mon, 14 Apr 2025 00:46:43 +0800 Subject: [PATCH] update: status of schedule when no proxy available --- 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 73e76a7..69f36de 100644 --- a/packages/crawler/mq/exec/snapshotTick.ts +++ b/packages/crawler/mq/exec/snapshotTick.ts @@ -277,7 +277,7 @@ export const takeBulkSnapshotForVideosWorker = async (job: Job) => { "mq", "fn:takeBulkSnapshotForVideosWorker", ); - await bulkSetSnapshotStatus(client, ids, "completed"); + await bulkSetSnapshotStatus(client, ids, "no_proxy"); await bulkScheduleSnapshot(client, aidsToFetch, "normal", Date.now() + 20 * MINUTE * Math.random()); return; } @@ -356,7 +356,7 @@ export const takeSnapshotForVideoWorker = async (job: Job) => { "mq", "fn:takeSnapshotForVideoWorker", ); - await setSnapshotStatus(client, id, "completed"); + await setSnapshotStatus(client, id, "no_proxy"); await scheduleSnapshot(client, aid, type, Date.now() + retryInterval); return; }