Skip to content

Commit 6dd8e06

Browse files
committed
Fix a reference to connection pool nodes
1 parent 2f4b247 commit 6dd8e06

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

lib/Pipeline.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -343,7 +343,7 @@ Pipeline.prototype.exec = function (callback: Callback): Promise<Array<any>> {
343343
if (_this.isCluster) {
344344
node = {
345345
slot: pipelineSlot,
346-
redis: _this.redis.connectionPool.nodes.all[_this.preferKey],
346+
redis: _this.redis.connectionPool.getNodes()[_this.preferKey],
347347
};
348348
}
349349

0 commit comments

Comments
 (0)