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; }