We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 49e434e commit d000b16Copy full SHA for d000b16
redis/connection.py
@@ -1378,6 +1378,7 @@ def __init__(
1378
# will notice the first thread already did the work and simply
1379
# release the lock.
1380
self._fork_lock = threading.Lock()
1381
+ self._lock = threading.Lock()
1382
self.reset()
1383
1384
def __repr__(self) -> (str, str):
@@ -1395,7 +1396,6 @@ def get_protocol(self):
1395
1396
return self.connection_kwargs.get("protocol", None)
1397
1398
def reset(self) -> None:
- self._lock = threading.Lock()
1399
self._created_connections = 0
1400
self._available_connections = []
1401
self._in_use_connections = set()
0 commit comments