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

update: minimum interval for snapshotMilestoneVideo

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-03-09 22:52:12 +08:00
parent a138f6d572
commit 81b95c9569
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -10,6 +10,7 @@ import { redis } from "lib/db/redis.ts";
import { NetSchedulerError } from "lib/mq/scheduler.ts"; import { NetSchedulerError } from "lib/mq/scheduler.ts";
import logger from "lib/log/logger.ts"; import logger from "lib/log/logger.ts";
import { formatSeconds } from "lib/utils/formatSeconds.ts"; import { formatSeconds } from "lib/utils/formatSeconds.ts";
import { truncate } from "lib/utils/truncate.ts";
async function snapshotScheduled(aid: number) { async function snapshotScheduled(aid: number) {
try { try {
@ -122,7 +123,8 @@ export const takeSnapshotForMilestoneVideoWorker = async (job: Job) => {
const eta = viewsToIncrease / (incrementSpeed + DELTA); const eta = viewsToIncrease / (incrementSpeed + DELTA);
const scheduledNextSnapshotDelay = eta * SECOND / 3; const scheduledNextSnapshotDelay = eta * SECOND / 3;
const maxInterval = 20 * MINUTE; const maxInterval = 20 * MINUTE;
const delay = Math.min(scheduledNextSnapshotDelay, maxInterval); const minInterval = 1 * SECOND;
const delay = truncate(scheduledNextSnapshotDelay, minInterval, maxInterval);
await SnapshotQueue.add("snapshotMilestoneVideo", { await SnapshotQueue.add("snapshotMilestoneVideo", {
aid, aid,
currentViews: stat.views, currentViews: stat.views,