diff --git a/src/classes/redis-connection.ts b/src/classes/redis-connection.ts index 08cf4472ea..9621f4d8be 100644 --- a/src/classes/redis-connection.ts +++ b/src/classes/redis-connection.ts @@ -52,7 +52,7 @@ export class RedisConnection extends EventEmitter { private readonly initializing: Promise; private version: string; - protected packageVersion: string; + protected packageVersion = packageVersion; private skipVersionCheck: boolean; private handleClientError: (e: Error) => void; private handleClientClose: () => void; @@ -65,7 +65,6 @@ export class RedisConnection extends EventEmitter { skipVersionCheck = false, ) { super(); - this.packageVersion = packageVersion; if (!isRedisInstance(opts)) { this.checkBlockingOptions(overrideMessage, opts); diff --git a/src/classes/scripts.ts b/src/classes/scripts.ts index 330b6697bf..7e42f15ed6 100644 --- a/src/classes/scripts.ts +++ b/src/classes/scripts.ts @@ -36,19 +36,17 @@ import { import { ErrorCode } from '../enums'; import { array2obj, getParentKey, isRedisVersionLowerThan } from '../utils'; import { ChainableCommander } from 'ioredis'; -import { version } from '../version'; +import { version as packageVersion } from '../version'; export type JobData = [JobJsonRaw | number, string?]; export class Scripts { - protected version; + protected version = packageVersion; moveToFinishedKeys: (string | undefined)[]; constructor(protected queue: MinimalQueue) { const queueKeys = this.queue.keys; - this.version = version; - this.moveToFinishedKeys = [ queueKeys.wait, queueKeys.active, diff --git a/src/classes/worker.ts b/src/classes/worker.ts index 05146e9f7b..e6984e046f 100644 --- a/src/classes/worker.ts +++ b/src/classes/worker.ts @@ -39,7 +39,7 @@ import { import { SpanKind, TelemetryAttributes } from '../enums'; import { JobScheduler } from './job-scheduler'; -// 10 seconds is the maximum time a BRPOPLPUSH can block. +// 10 seconds is the maximum time a BZPOPMIN can block. const maximumBlockTimeout = 10; // 30 seconds is the maximum limit until.