From bae1f84beaf4a1443a0f722e1d27f20f4563171e Mon Sep 17 00:00:00 2001
From: alikia2x <alikia2x@outlook.com>
Date: Mon, 14 Apr 2025 00:39:17 +0800
Subject: [PATCH] add: logging for releasing locks

---
 packages/crawler/src/worker.ts | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/packages/crawler/src/worker.ts b/packages/crawler/src/worker.ts
index 065857e..d002ece 100644
--- a/packages/crawler/src/worker.ts
+++ b/packages/crawler/src/worker.ts
@@ -1,6 +1,6 @@
 import { ConnectionOptions, Job, Worker } from "bullmq";
 import { collectSongsWorker, getLatestVideosWorker } from "mq/executors.ts";
-import { redis } from "../../core/db/redis.ts";
+import { redis } from "@core/db/redis.ts";
 import logger from "log/logger.ts";
 import { lockManager } from "mq/lockManager.ts";
 import { WorkerError } from "mq/schema.ts";
@@ -100,4 +100,5 @@ snapshotWorker.on("error", (err) => {
 snapshotWorker.on("closed", async () => {
 	await lockManager.releaseLock("dispatchRegularSnapshots");
 	await lockManager.releaseLock("dispatchArchiveSnapshots");
+	logger.log(`Released lock: dispatchArchiveSnapshots, dispatchRegularSnapshots`, "mq", "snapshotWorker:on:closed");
 });