Restrict async tests to > 3.8

Author: vladvildanov

tests/test_asyncio/conftest.py

@@ -1,6 +1,6 @@
 import random
 from contextlib import asynccontextmanager as _asynccontextmanager
-from typing import Union, Iterator, Any
+from typing import Union
 from unittest.mock import AsyncMock
 
 import pytest
@@ -18,12 +18,6 @@
 from .compat import mock
 
 
-class AwaitableMock(AsyncMock):
-    def __await__(self) -> Iterator[Any]:
-        self.await_count += 1
-        return iter([])
-
-
 async def _get_info(redis_url):
     client = redis.Redis.from_url(redis_url)
     info = await client.info()
@@ -228,13 +222,13 @@ async def mock_cluster_resp_slaves(create_redis, **kwargs):
 
 @pytest_asyncio.fixture()
 def mock_connection() -> Connection:
-    mock_connection = AwaitableMock(spec=Connection)
+    mock_connection = AsyncMock(spec=Connection)
     return mock_connection
 
 
 @pytest_asyncio.fixture()
 def mock_pool() -> ConnectionPool:
-    mock_pool = AwaitableMock(spec=ConnectionPool)
+    mock_pool = AsyncMock(spec=ConnectionPool)
     return mock_pool
 
 

tests/test_asyncio/test_connection.py

@@ -1,5 +1,6 @@
 import asyncio
 import socket
+import sys
 import types
 from errno import ECONNREFUSED
 from unittest.mock import patch
@@ -316,6 +317,7 @@ async def get_redis_connection():
 
 
 @pytest.mark.onlynoncluster
+@pytest.mark.skipif(sys.version_info < (3, 8), reason="requires python > 3.8")
 async def test_client_do_not_retry_write_on_read_failure(mock_connection, mock_pool):
     mock_connection.send_command.return_value = True
     mock_connection.read_response.side_effect = [
@@ -341,6 +343,7 @@ async def test_client_do_not_retry_write_on_read_failure(mock_connection, mock_p
 
 
 @pytest.mark.onlynoncluster
+@pytest.mark.skipif(sys.version_info < (3, 8), reason="requires python > 3.8")
 async def test_pipeline_immediate_do_not_retry_write_on_read_failure(
     mock_connection, mock_pool
 ):