From 08e1e22dad4707386b0f5524d0dee5a3dd8163e9 Mon Sep 17 00:00:00 2001 From: Alex Holliday Date: Mon, 19 May 2025 12:26:25 -0700 Subject: [PATCH] change failed job log level to error --- server/service/JobQueue/JobQueueHelper.js | 17 ++++++----------- 1 file changed, 6 insertions(+), 11 deletions(-) diff --git a/server/service/JobQueue/JobQueueHelper.js b/server/service/JobQueue/JobQueueHelper.js index 99a6430e6..de1e00fb8 100644 --- a/server/service/JobQueue/JobQueueHelper.js +++ b/server/service/JobQueue/JobQueueHelper.js @@ -143,10 +143,11 @@ class JobQueueHelper { }); worker.on("failed", (job, error, prev) => { - this.logger.warn({ - message: `Worker ${queueName} is failed with msg: ${error}`, - service: SERVICE_NAME, - method: "createWorker:failed", + this.logger.error({ + message: `Worker ${queueName} is failed with msg: ${error.message}`, + service: error?.service ?? SERVICE_NAME, + method: error?.method ?? "createWorker:failed", + stack: error?.stack, }); }); @@ -293,13 +294,7 @@ class JobQueueHelper { await job.updateProgress(100); return true; } catch (error) { - this.logger.error({ - message: error.message, - service: error.service ?? SERVICE_NAME, - method: error.method ?? "createJobHandler", - details: `Error processing job ${job.id}: ${error.message}`, - stack: error.stack, - }); + await job.updateProgress(100); throw error; } };