Skip to content

Commit 88f7e54

Browse files
committed
Added support for BlockingConnectionPool
1 parent 339735c commit 88f7e54

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

redis/connection.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1541,7 +1541,14 @@ def reset(self):
15411541

15421542
def make_connection(self):
15431543
"Make a fresh connection."
1544-
connection = self.connection_class(**self.connection_kwargs)
1544+
if self._cache is not None and self._cache_conf is not None:
1545+
connection = CacheProxyConnection(
1546+
self.connection_class(**self.connection_kwargs),
1547+
self._cache,
1548+
self._cache_conf
1549+
)
1550+
else:
1551+
connection = self.connection_class(**self.connection_kwargs)
15451552
self._connections.append(connection)
15461553
return connection
15471554

0 commit comments

Comments
 (0)