diff --git a/packages/backend/src/config.ts b/packages/backend/src/config.ts index 3d7475fd83..2add8f7ac9 100644 --- a/packages/backend/src/config.ts +++ b/packages/backend/src/config.ts @@ -108,9 +108,9 @@ export type Mixin = { mediaProxy: string; externalMediaProxyEnabled: boolean; videoThumbnailGenerator: string | null; - redis: RedisOptions; - redisForPubsub: RedisOptions; - redisForJobQueue: RedisOptions; + redis: RedisOptions & RedisOptionsSource; + redisForPubsub: RedisOptions & RedisOptionsSource; + redisForJobQueue: RedisOptions & RedisOptionsSource; }; export type Config = Source & Mixin; diff --git a/packages/backend/src/queue/const.ts b/packages/backend/src/queue/const.ts index 18ad542c87..d49951a1c3 100644 --- a/packages/backend/src/queue/const.ts +++ b/packages/backend/src/queue/const.ts @@ -14,7 +14,10 @@ export const QUEUE = { export function baseQueueOptions(config: Config, queueName: typeof QUEUE[keyof typeof QUEUE]): Bull.QueueOptions { return { - connection: config.redisForJobQueue, + connection: { + ...config.redisForJobQueue, + keyPrefix: undefined + }, prefix: config.redisForJobQueue.prefix ? `${config.redisForJobQueue.prefix}:queue:${queueName}` : `queue:${queueName}`, }; }