fix?

Secineralyr · Jul 20, 2023 · dfd6b4f · dfd6b4f
1 parent 3d213f1
commit dfd6b4f
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git 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
@@ -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}`,
 	};
 }