alikia2x/cvsa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: did not release db client before quiting

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-03-27 01:31:54 +08:00
parent 92678066a7
commit c80b047e0c
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/mq/exec/snapshotTick.ts
View File

@ -195,10 +195,14 @@ export const takeSnapshotForVideoWorker = async (job: Job) => {
const retryInterval = type === "milestone" ? 5 * SECOND : 2 * MINUTE; const retryInterval = type === "milestone" ? 5 * SECOND : 2 * MINUTE;
const exists = await snapshotScheduleExists(client, id); const exists = await snapshotScheduleExists(client, id);
if (!exists) { if (!exists) {
client.release();
return; return;
} }
const status = await getBiliVideoStatus(client, aid); const status = await getBiliVideoStatus(client, aid);
if (status !== 0) return `REFUSE_WORKING_BILI_STATUS_${status}` if (status !== 0) {
client.release();
return `REFUSE_WORKING_BILI_STATUS_${status}`;
}
try { try {
await setSnapshotStatus(client, id, "processing"); await setSnapshotStatus(client, id, "processing");
const stat = await insertVideoSnapshot(client, aid, task); const stat = await insertVideoSnapshot(client, aid, task);