diff --git a/package-lock.json b/package-lock.json index 1af6fe4..115f23f 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,12 +1,12 @@ { "name": "@athenna/queue", - "version": "5.19.0", + "version": "5.20.0", "lockfileVersion": 3, "requires": true, "packages": { "": { "name": "@athenna/queue", - "version": "5.19.0", + "version": "5.20.0", "license": "MIT", "dependencies": { "@aws-sdk/client-sqs": "^3.1009.0" diff --git a/package.json b/package.json index a021fea..4f41972 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@athenna/queue", - "version": "5.19.0", + "version": "5.20.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 1c6f775..02d5418 100644 --- a/src/handlers/AwsSqsDriverExceptionHandler.ts +++ b/src/handlers/AwsSqsDriverExceptionHandler.ts @@ -34,6 +34,10 @@ export class AwsSqsDriverExceptionHandler extends ExceptionHandler { const attempts = Math.max(driver.attempts - receiveCount, 0) const shouldRetry = attempts > 0 + // eslint-disable-next-line @typescript-eslint/ban-ts-comment + // @ts-ignore + await super.handle({ job, error, driver, stopHeartbeat, requeueJitterMs }) + if (Config.is('worker.logger.enabled', true)) { if (Config.is('worker.logger.prettifyException')) { Log.channelOrVanilla('exception').error( diff --git a/src/handlers/DatabaseDriverExceptionHandler.ts b/src/handlers/DatabaseDriverExceptionHandler.ts index 4d5681f..e555334 100644 --- a/src/handlers/DatabaseDriverExceptionHandler.ts +++ b/src/handlers/DatabaseDriverExceptionHandler.ts @@ -26,6 +26,10 @@ export class DatabaseDriverExceptionHandler extends ExceptionHandler { }: DatabaseDriverExceptionHandlerContext) { const shouldRetry = job.attempts > 0 + // eslint-disable-next-line @typescript-eslint/ban-ts-comment + // @ts-ignore + await super.handle({ job, error, driver, requeueJitterMs }) + if (Config.is('worker.logger.enabled', true)) { if (Config.is('worker.logger.prettifyException')) { Log.channelOrVanilla('exception').error( diff --git a/src/handlers/MemoryDriverExceptionHandler.ts b/src/handlers/MemoryDriverExceptionHandler.ts index da76d8f..c10f626 100644 --- a/src/handlers/MemoryDriverExceptionHandler.ts +++ b/src/handlers/MemoryDriverExceptionHandler.ts @@ -26,6 +26,10 @@ export class MemoryDriverExceptionHandler extends ExceptionHandler { }: MemoryDriverExceptionHandlerContext) { const shouldRetry = job.attempts > 0 + // eslint-disable-next-line @typescript-eslint/ban-ts-comment + // @ts-ignore + await super.handle({ job, error, driver, requeueJitterMs }) + job.reservedUntil = null if (Config.is('worker.logger.enabled', true)) {