change failed job log level to error

This commit is contained in:
Alex Holliday committed 2025-05-19 12:26:25 -07:00
1 parent 885c63b147
commit 08e1e22dad
1 file changed
+6 -11
+6 -11
View File
@@ -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;
}
};