diff --git a/package-lock.json b/package-lock.json index 9bc4324..6ad68b2 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,12 +1,12 @@ { "name": "@athenna/queue", - "version": "5.25.0", + "version": "5.27.0", "lockfileVersion": 3, "requires": true, "packages": { "": { "name": "@athenna/queue", - "version": "5.25.0", + "version": "5.27.0", "license": "MIT", "dependencies": { "@aws-sdk/client-sqs": "^3.1019.0" diff --git a/package.json b/package.json index 1b1fe2c..3d97813 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@athenna/queue", - "version": "5.25.0", + "version": "5.27.0", "description": "The Athenna queue handler.", "license": "MIT", "author": "João Lenon ", diff --git a/src/handlers/AwsSqsDriverExceptionHandler.ts b/src/handlers/AwsSqsDriverExceptionHandler.ts index da53f20..bd2ab30 100644 --- a/src/handlers/AwsSqsDriverExceptionHandler.ts +++ b/src/handlers/AwsSqsDriverExceptionHandler.ts @@ -38,23 +38,25 @@ export class AwsSqsDriverExceptionHandler extends ExceptionHandler { // @ts-ignore await super.handle({ job, error, driver, stopHeartbeat, requeueJitterMs }) - if (Config.is('worker.logger.prettifyException')) { - Log.channelOrVanilla('exception').error( - await error.toAthennaException().prettify() - ) - } else { - Log.channelOrVanilla('exception').error({ - msg: `failed to process job: ${error.message}`, - queue: driver.queueName, - deadletter: driver.deadletter, - name: error.name, - code: error.code, - help: error.help, - details: error.details, - metadata: error.metadata, - stack: error.stack, - job - }) + if (Config.is('worker.logger.enabled', true)) { + if (Config.is('worker.logger.prettifyException', true)) { + Log.channelOrVanilla('exception').error( + await error.toAthennaException().prettify() + ) + } else { + Log.channelOrVanilla('exception').error({ + msg: `failed to process job: ${error.message}`, + queue: driver.queueName, + deadletter: driver.deadletter, + name: error.name, + code: error.code, + help: error.help, + details: error.details, + metadata: error.metadata, + stack: error.stack, + job + }) + } } if (shouldRetry) { diff --git a/src/handlers/DatabaseDriverExceptionHandler.ts b/src/handlers/DatabaseDriverExceptionHandler.ts index f1aa7dd..0903346 100644 --- a/src/handlers/DatabaseDriverExceptionHandler.ts +++ b/src/handlers/DatabaseDriverExceptionHandler.ts @@ -30,23 +30,25 @@ export class DatabaseDriverExceptionHandler extends ExceptionHandler { // @ts-ignore await super.handle({ job, error, driver, requeueJitterMs }) - if (Config.is('worker.logger.prettifyException')) { - Log.channelOrVanilla('exception').error( - await error.toAthennaException().prettify() - ) - } else { - Log.channelOrVanilla('exception').error({ - msg: `failed to process job: ${error.message}`, - queue: driver.queueName, - deadletter: driver.deadletter, - name: error.name, - code: error.code, - help: error.help, - details: error.details, - metadata: error.metadata, - stack: error.stack, - job - }) + if (Config.is('worker.logger.enabled', true)) { + if (Config.is('worker.logger.prettifyException', true)) { + Log.channelOrVanilla('exception').error( + await error.toAthennaException().prettify() + ) + } else { + Log.channelOrVanilla('exception').error({ + msg: `failed to process job: ${error.message}`, + queue: driver.queueName, + deadletter: driver.deadletter, + name: error.name, + code: error.code, + help: error.help, + details: error.details, + metadata: error.metadata, + stack: error.stack, + job + }) + } } if (!shouldRetry) { diff --git a/src/handlers/MemoryDriverExceptionHandler.ts b/src/handlers/MemoryDriverExceptionHandler.ts index 852d79f..afebbab 100644 --- a/src/handlers/MemoryDriverExceptionHandler.ts +++ b/src/handlers/MemoryDriverExceptionHandler.ts @@ -32,23 +32,25 @@ export class MemoryDriverExceptionHandler extends ExceptionHandler { job.reservedUntil = null - if (Config.is('worker.logger.prettifyException')) { - Log.channelOrVanilla('exception').error( - await error.toAthennaException().prettify() - ) - } else { - Log.channelOrVanilla('exception').error({ - msg: `failed to process job: ${error.message}`, - queue: driver.queueName, - deadletter: driver.deadletter, - name: error.name, - code: error.code, - help: error.help, - details: error.details, - metadata: error.metadata, - stack: error.stack, - job - }) + if (Config.is('worker.logger.enabled', true)) { + if (Config.is('worker.logger.prettifyException', true)) { + Log.channelOrVanilla('exception').error( + await error.toAthennaException().prettify() + ) + } else { + Log.channelOrVanilla('exception').error({ + msg: `failed to process job: ${error.message}`, + queue: driver.queueName, + deadletter: driver.deadletter, + name: error.name, + code: error.code, + help: error.help, + details: error.details, + metadata: error.metadata, + stack: error.stack, + job + }) + } } if (shouldRetry) {