Fixed tests

Author: vladvildanov

redis/event.py

@@ -96,7 +96,7 @@ def __init__(
         }
 
         self._lock = threading.Lock()
-        self._async_lock = asyncio.Lock()
+        self._async_lock = None
 
         if event_listeners:
             self.register_listeners(event_listeners)
@@ -109,6 +109,9 @@ def dispatch(self, event: object):
                 listener.listen(event)
 
     async def dispatch_async(self, event: object):
+        if self._async_lock is None:
+            self._async_lock = asyncio.Lock()
+
         async with self._async_lock:
             listeners = self._event_listeners_mapping.get(type(event), [])
 

tasks.py

@@ -74,11 +74,11 @@ def cluster_tests(c, uvloop=False, protocol=2, profile=False):
     cluster_tls_url = "rediss://localhost:27379/0"
     if uvloop:
         run(
-            f"pytest {profile_arg} --protocol={protocol}  --ignore=tests/test_scenario  --cov=./ --cov-report=xml:coverage_cluster_resp{protocol}_uvloop.xml -m 'not onlynoncluster and not redismod' --redis-url={cluster_url} --redis-ssl-url={cluster_tls_url} --junit-xml=cluster-resp{protocol}-uvloop-results.xml --uvloop"
+            f"pytest {profile_arg} --protocol={protocol}  --ignore=tests/test_scenario --ignore=tests/test_asyncio/test_scenario  --cov=./ --cov-report=xml:coverage_cluster_resp{protocol}_uvloop.xml -m 'not onlynoncluster and not redismod' --redis-url={cluster_url} --redis-ssl-url={cluster_tls_url} --junit-xml=cluster-resp{protocol}-uvloop-results.xml --uvloop"
         )
     else:
         run(
-            f"pytest  {profile_arg} --protocol={protocol}  --ignore=tests/test_scenario  --cov=./ --cov-report=xml:coverage_cluster_resp{protocol}.xml -m 'not onlynoncluster and not redismod' --redis-url={cluster_url} --redis-ssl-url={cluster_tls_url} --junit-xml=cluster-resp{protocol}-results.xml"
+            f"pytest  {profile_arg} --protocol={protocol}  --ignore=tests/test_scenario --ignore=tests/test_asyncio/test_scenario  --cov=./ --cov-report=xml:coverage_cluster_resp{protocol}.xml -m 'not onlynoncluster and not redismod' --redis-url={cluster_url} --redis-ssl-url={cluster_tls_url} --junit-xml=cluster-resp{protocol}-results.xml"
         )
 
 

tests/test_maint_notifications_handling.py

@@ -330,6 +330,9 @@ def setsockopt(self, level, optname, value):
         """Simulate setting socket options."""
         pass
 
+    def setblocking(self, blocking):
+        pass
+
     def getpeername(self):
         """Simulate getting peer name."""
         return self.address