Fix lock is not instantiated on UnixDomainSocketConnection init (#1249)

Fixes #1249
aio-libs-abandoned · Dec 23, 2021 · d52930f · d52930f
1 parent 224f843
commit d52930f
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 deletions.
diff --git a/CHANGES/1249.bugfix b/CHANGES/1249.bugfix
@@ -0,0 +1 @@
+Instantiate lock on UnixDomainSocketConnection init.
diff --git a/CONTRIBUTORS.txt b/CONTRIBUTORS.txt
@@ -22,6 +22,7 @@ Chao Guo <jeffguorg>
 Contributors
 Daniil Kozhanov
 David Francos
+David Testé
 Dima Kit
 Dima Kruk
 Dmitry Vasilishin <dmvass>

diff --git a/aioredis/connection.py b/aioredis/connection.py
@@ -1122,6 +1122,7 @@ def __init__(
         self._parser = parser_class(socket_read_size=socket_read_size)
         self._connect_callbacks = []
         self._buffer_cutoff = 6000
+        self._lock = asyncio.Lock()
 
     def repr_pieces(self) -> Iterable[Tuple[str, Union[str, int]]]:
         pieces = [