diff --git a/lib/mq/exec/snapshotTick.ts b/lib/mq/exec/snapshotTick.ts index 93f0907..63dec8d 100644 --- a/lib/mq/exec/snapshotTick.ts +++ b/lib/mq/exec/snapshotTick.ts @@ -10,7 +10,6 @@ import { scheduleSnapshot, setSnapshotStatus, snapshotScheduleExists, - videoHasProcessingSchedule, } from "lib/db/snapshotSchedule.ts"; import { Client } from "https://deno.land/x/postgres@v0.19.3/mod.ts"; import { HOUR, MINUTE, SECOND, WEEK } from "$std/datetime/constants.ts"; @@ -193,10 +192,6 @@ export const takeSnapshotForVideoWorker = async (job: Job) => { return; } try { - if (await videoHasProcessingSchedule(client, aid)) { - return `ALREADY_PROCESSING`; - } - await setSnapshotStatus(client, id, "processing"); const stat = await insertVideoSnapshot(client, aid, task); if (typeof stat === "number") { await setBiliVideoStatus(client, aid, stat);