alikia2x/cvsa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add: logging for releasing locks

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-04-14 00:39:17 +08:00
parent 21c918f1fa
commit bae1f84bea
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
packages/crawler/src/worker.ts
View File

@ -1,6 +1,6 @@
import { ConnectionOptions, Job, Worker } from "bullmq"; import { ConnectionOptions, Job, Worker } from "bullmq";
import { collectSongsWorker, getLatestVideosWorker } from "mq/executors.ts"; 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 logger from "log/logger.ts";
import { lockManager } from "mq/lockManager.ts"; import { lockManager } from "mq/lockManager.ts";
import { WorkerError } from "mq/schema.ts"; import { WorkerError } from "mq/schema.ts";
@ -100,4 +100,5 @@ snapshotWorker.on("error", (err) => {
snapshotWorker.on("closed", async () => { snapshotWorker.on("closed", async () => {
await lockManager.releaseLock("dispatchRegularSnapshots"); await lockManager.releaseLock("dispatchRegularSnapshots");
await lockManager.releaseLock("dispatchArchiveSnapshots"); await lockManager.releaseLock("dispatchArchiveSnapshots");
logger.log(`Released lock: dispatchArchiveSnapshots, dispatchRegularSnapshots`, "mq", "snapshotWorker:on:closed");
}); });