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

fix: ignored the case of inserting schedule when type = 'milestone' in scheduleSnapshot

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-04-15 22:06:14 +08:00
parent 288e4f9571
commit 6eaaf921d6
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
packages/crawler/db/snapshotSchedule.ts
View File

@ -182,11 +182,15 @@ export async function scheduleSnapshot(
force: boolean = false, force: boolean = false,
) { ) {
let adjustedTime = new Date(targetTime); let adjustedTime = new Date(targetTime);
if (type == "milestone") { const hashActiveSchedule = await videoHasActiveScheduleWithType(client, aid, type);
await client.queryObject( if (type == "milestone" && hashActiveSchedule) {
`UPDATE snapshot_schedule SET started_at = $1 WHERE aid = $2 AND type = 'milestone' AND status = 'pending'`, await client.queryObject(`
[adjustedTime, aid], UPDATE snapshot_schedule
); SET started_at = $1
WHERE aid = $2
AND type = 'milestone'
AND (status = 'pending' OR status = 'processing')
`, [adjustedTime, aid]);
logger.log( logger.log(
`Updated snapshot schedule for ${aid} at ${adjustedTime.toISOString()}`, `Updated snapshot schedule for ${aid} at ${adjustedTime.toISOString()}`,
"mq", "mq",
@ -194,7 +198,7 @@ export async function scheduleSnapshot(
); );
return; return;
} }
if (await videoHasActiveScheduleWithType(client, aid, type) && !force) return; if (hashActiveSchedule && !force) return;
if (type !== "milestone" && type !== "new") { if (type !== "milestone" && type !== "new") {
adjustedTime = await adjustSnapshotTime(new Date(targetTime), 2000, redis); adjustedTime = await adjustSnapshotTime(new Date(targetTime), 2000, redis);
} }