From 9770a487bc2add30472e4917f11d817cdabcce8e Mon Sep 17 00:00:00 2001 From: alikia2x Date: Tue, 21 Oct 2025 22:25:57 +0800 Subject: [PATCH] add: logging for debugging --- packages/crawler/db/snapshotSchedule.ts | 13 ------------- packages/crawler/mq/exec/archiveSnapshots.ts | 2 +- 2 files changed, 1 insertion(+), 14 deletions(-) diff --git a/packages/crawler/db/snapshotSchedule.ts b/packages/crawler/db/snapshotSchedule.ts index 4fdcc1e..f5b5e07 100644 --- a/packages/crawler/db/snapshotSchedule.ts +++ b/packages/crawler/db/snapshotSchedule.ts @@ -246,12 +246,8 @@ export async function adjustSnapshotTime( const initialOffset = currentWindow + Math.max(targetOffset, 0); - let timePerIteration: number; const MAX_ITERATIONS = 2880; - let iters = 0; - const t = performance.now(); for (let i = initialOffset; i < MAX_ITERATIONS; i++) { - iters++; const offset = i; const count = await getWindowCount(redisClient, offset); @@ -267,20 +263,11 @@ export async function adjustSnapshotTime( const now = new Date(); if (delayedDate.getTime() < now.getTime()) { - const elapsed = performance.now() - t; - timePerIteration = elapsed / (i + 1); - logger.log(`${timePerIteration.toFixed(3)}ms * ${iters} iterations`, "perf", "fn:adjustSnapshotTime"); return now; } - const elapsed = performance.now() - t; - timePerIteration = elapsed / (i + 1); - logger.log(`${timePerIteration.toFixed(3)}ms * ${iters} iterations`, "perf", "fn:adjustSnapshotTime"); return delayedDate; } } - const elapsed = performance.now() - t; - timePerIteration = elapsed / MAX_ITERATIONS; - logger.log(`${timePerIteration.toFixed(3)}ms * ${MAX_ITERATIONS} iterations`, "perf", "fn:adjustSnapshotTime"); return expectedStartTime; } diff --git a/packages/crawler/mq/exec/archiveSnapshots.ts b/packages/crawler/mq/exec/archiveSnapshots.ts index acfc54b..8f8f18a 100644 --- a/packages/crawler/mq/exec/archiveSnapshots.ts +++ b/packages/crawler/mq/exec/archiveSnapshots.ts @@ -46,7 +46,7 @@ export const archiveSnapshotsWorker = async (_job: Job) => { unit: "hour" }); logger.log( - `Scheduled archive snapshot for aid ${aid} in ${formatted}.`, + `Scheduled archive snapshot for aid ${aid} in ${formatted}. date: ${nextSaturday(date).toUTCString()}, timestamp: ${nextSaturday(date).getTime()}`, "mq", "fn:archiveSnapshotsWorker" );