From b2edaf8fc42a6b808008746cf427785602a0fa05 Mon Sep 17 00:00:00 2001 From: alikia2x Date: Sun, 30 Mar 2025 21:16:05 +0800 Subject: [PATCH] improve: prevent Infinity for getAdjustedShortTermETA --- 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 abec4f6..32e7b23 100644 --- a/packages/crawler/mq/exec/snapshotTick.ts +++ b/packages/crawler/mq/exec/snapshotTick.ts @@ -109,7 +109,7 @@ const log = (value: number, base: number = 10) => Math.log(value) / Math.log(bas * @param aid - aid of the video * @returns ETA in hours */ -const getAdjustedShortTermETA = async (client: Client, aid: number) => { +export const getAdjustedShortTermETA = async (client: Client, aid: number) => { const latestSnapshot = await getLatestSnapshot(client, aid); // Immediately dispatch a snapshot if there is no snapshot yet if (!latestSnapshot) return 0; @@ -117,7 +117,7 @@ const getAdjustedShortTermETA = async (client: Client, aid: number) => { if (!snapshotsEnough) return 0; const currentTimestamp = new Date().getTime(); - const timeIntervals = [3 * MINUTE, 20 * MINUTE, 1 * HOUR, 3 * HOUR, 6 * HOUR]; + const timeIntervals = [3 * MINUTE, 20 * MINUTE, 1 * HOUR, 3 * HOUR, 6 * HOUR, 72 * HOUR]; const DELTA = 0.00001; let minETAHours = Infinity;