From 2c51c3c09cd9c9a1d7228edfab67ac388abc3998 Mon Sep 17 00:00:00 2001 From: alikia2x Date: Wed, 26 Mar 2025 23:04:08 +0800 Subject: [PATCH] add: log for getRegularSnapshotInterval --- lib/mq/exec/snapshotTick.ts | 2 ++ 1 file changed, 2 insertions(+) diff --git a/lib/mq/exec/snapshotTick.ts b/lib/mq/exec/snapshotTick.ts index 4312caf..9428ffe 100644 --- a/lib/mq/exec/snapshotTick.ts +++ b/lib/mq/exec/snapshotTick.ts @@ -171,6 +171,7 @@ export const regularSnapshotsWorker = async (_job: Job) => { const now = Date.now(); const lastSnapshotedAt = latestSnapshot?.time ?? now; const interval = await getRegularSnapshotInterval(client, aid); + logger.log(`Schedule regular snapshot for aid ${aid} in ${interval} hours.`, "mq") const targetTime = truncate(lastSnapshotedAt + interval * HOUR, now + 1, now + 100000 * WEEK); await scheduleSnapshot(client, aid, "normal", targetTime); if (now - startedAt > 25 * MINUTE) { @@ -207,6 +208,7 @@ export const takeSnapshotForVideoWorker = async (job: Job) => { await setSnapshotStatus(client, id, "completed"); if (type === "normal") { const interval = await getRegularSnapshotInterval(client, aid); + logger.log(`Schedule regular snapshot for aid ${aid} in ${interval} hours.`, "mq") await scheduleSnapshot(client, aid, type, Date.now() + interval * HOUR); return `DONE`; } else if (type === "new") {