diff --git a/packages/crawler/mq/exec/snapshotTick.ts b/packages/crawler/mq/exec/snapshotTick.ts index 8fbc50f..00ae1bc 100644 --- a/packages/crawler/mq/exec/snapshotTick.ts +++ b/packages/crawler/mq/exec/snapshotTick.ts @@ -159,7 +159,7 @@ export const archiveSnapshotsWorker = async (_job: Job) => { const now = Date.now(); const lastSnapshotedAt = latestSnapshot?.time ?? now; const interval = 168; - logger.log(`Scheduled archive snapshot for aid ${aid} in ${interval} hours.`, "mq"); + logger.log(`Scheduled archive snapshot for aid ${aid} in ${interval} hours.`, "mq", "fn:archiveSnapshotsWorker"); const targetTime = lastSnapshotedAt + interval * HOUR; await scheduleSnapshot(client, aid, "archive", targetTime); if (now - startedAt > 250 * MINUTE) { diff --git a/packages/crawler/src/worker.ts b/packages/crawler/src/worker.ts index 9c5a902..065857e 100644 --- a/packages/crawler/src/worker.ts +++ b/packages/crawler/src/worker.ts @@ -99,4 +99,5 @@ snapshotWorker.on("error", (err) => { snapshotWorker.on("closed", async () => { await lockManager.releaseLock("dispatchRegularSnapshots"); + await lockManager.releaseLock("dispatchArchiveSnapshots"); });