From 432634c5a3347262c77ff420cc2a49b4e407891e Mon Sep 17 00:00:00 2001 From: fengmk2 Date: Wed, 2 Apr 2025 09:34:13 +0000 Subject: [PATCH] feat(server): enable job queue log (#11390) --- packages/backend/server/src/base/job/queue/executor.ts | 4 ++-- packages/backend/server/src/base/job/queue/queue.ts | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/packages/backend/server/src/base/job/queue/executor.ts b/packages/backend/server/src/base/job/queue/executor.ts index 8a06bc3608..5e82e49b33 100644 --- a/packages/backend/server/src/base/job/queue/executor.ts +++ b/packages/backend/server/src/base/job/queue/executor.ts @@ -72,9 +72,9 @@ export class JobExecutor implements OnModuleDestroy { const signature = `[${name}] (${handler.name})`; try { - this.logger.debug(`Job started: ${signature}`); + this.logger.log(`Job started: ${signature}`); const ret = await handler.fn(payload); - this.logger.debug(`Job finished: ${signature}`); + this.logger.log(`Job finished: ${signature}, signal=${ret}`); return ret; } catch (e) { this.logger.error(`Job failed: ${signature}`, e); diff --git a/packages/backend/server/src/base/job/queue/queue.ts b/packages/backend/server/src/base/job/queue/queue.ts index 2515a55b0d..9900cfecbe 100644 --- a/packages/backend/server/src/base/job/queue/queue.ts +++ b/packages/backend/server/src/base/job/queue/queue.ts @@ -15,7 +15,7 @@ export class JobQueue { const ns = namespace(name); const queue = this.getQueue(ns); const job = await queue.add(name, payload, opts); - this.logger.debug(`Job [${name}] added; id=${job.id}`); + this.logger.log(`Job [${name}] added; id=${job.id}`); return job; }