diff --git a/src/classes/queue.ts b/src/classes/queue.ts index d2ff19a2a2..e1dde0044f 100644 --- a/src/classes/queue.ts +++ b/src/classes/queue.ts @@ -485,12 +485,12 @@ export class Queue< * * @param id - identifier */ - async removeDeduplicationKey(id: string): Promise { - const client = await this.client; - - return client.del(`${this.keys.de}:${id}`); - } - + async removeDeduplicationKey(id: string): Promise { + const client = await this.client; + + return client.del(`${this.keys.de}:${id}`); + } + /** * Removes a repeatable job by its key. Note that the key is the one used * to store the repeatable job metadata and not one of the job iterations diff --git a/src/classes/scripts.ts b/src/classes/scripts.ts index d5df5b0ab3..39192f8635 100644 --- a/src/classes/scripts.ts +++ b/src/classes/scripts.ts @@ -596,7 +596,7 @@ export class Scripts { } } - finishedErrors = ({ + finishedErrors({ code, jobId, parentKey, @@ -608,7 +608,7 @@ export class Scripts { parentKey?: string; command: string; state?: string; - }): Error => { + }): Error { switch (code) { case ErrorCode.JobNotExist: return new Error(`Missing key for job ${jobId}. ${command}`); @@ -637,7 +637,7 @@ export class Scripts { default: return new Error(`Unknown code ${code} error for ${jobId}. ${command}`); } - }; + } private drainArgs(delayed: boolean): (string | number)[] { const queueKeys = this.queue.keys;