From 565c1389a19add005f5be9168eede0f67c6d04b6 Mon Sep 17 00:00:00 2001 From: "H. Temelski" Date: Wed, 30 Apr 2025 13:49:19 +0300 Subject: [PATCH 1/2] Infer the cluster pubsub client read only mode from the node type --- packages/client/lib/cluster/cluster-slots.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/client/lib/cluster/cluster-slots.ts b/packages/client/lib/cluster/cluster-slots.ts index 3a4adff73c4..a5434967e80 100644 --- a/packages/client/lib/cluster/cluster-slots.ts +++ b/packages/client/lib/cluster/cluster-slots.ts @@ -518,7 +518,7 @@ export default class RedisClusterSlots< node = index < this.masters.length ? this.masters[index] : this.replicas[index - this.masters.length], - client = this.#createClient(node, true); + client = this.#createClient(node, node.readonly); this.pubSubNode = { address: node.address, From c5a095715476af72847b0e5ed6cd8786df1d2af0 Mon Sep 17 00:00:00 2001 From: "H. Temelski" Date: Wed, 30 Apr 2025 15:40:22 +0300 Subject: [PATCH 2/2] Modify flag logic --- packages/client/lib/cluster/cluster-slots.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/client/lib/cluster/cluster-slots.ts b/packages/client/lib/cluster/cluster-slots.ts index a5434967e80..c2fde197f4f 100644 --- a/packages/client/lib/cluster/cluster-slots.ts +++ b/packages/client/lib/cluster/cluster-slots.ts @@ -518,7 +518,7 @@ export default class RedisClusterSlots< node = index < this.masters.length ? this.masters[index] : this.replicas[index - this.masters.length], - client = this.#createClient(node, node.readonly); + client = this.#createClient(node, index >= this.masters.length); this.pubSubNode = { address: node.address,