Fix CI tests

Author: eamsden

external_storage_redis/redis_asyncio.py

@@ -4,11 +4,13 @@
 
 import math
 from datetime import timedelta
-
-from redis.asyncio.client import Redis
+from typing import TYPE_CHECKING
 
 from external_storage_redis._client import RedisStorageDriverClient
 
+if TYPE_CHECKING:
+    from redis.asyncio.client import Redis
+
 
 class _RedisAsyncioStorageDriverClient(RedisStorageDriverClient):
     """Adapter that wraps a ``redis.asyncio.Redis`` client.

tests/external_storage_redis/conftest.py

@@ -3,15 +3,18 @@
 from __future__ import annotations
 
 from collections.abc import AsyncIterator
+from typing import TYPE_CHECKING
 
 import fakeredis.aioredis
 import pytest
 import pytest_asyncio
-from redis.asyncio.client import Redis
 
 from external_storage_redis import RedisStorageDriverClient
 from external_storage_redis.redis_asyncio import new_redis_asyncio_client
 
+if TYPE_CHECKING:
+    from redis.asyncio.client import Redis
+
 KEY_PREFIX = "test:payloads"
 
 

tests/external_storage_redis/test_redis.py

@@ -4,6 +4,8 @@
 
 import asyncio
 import hashlib
+import subprocess
+import sys
 from collections.abc import Callable, Coroutine
 from datetime import timedelta
 from functools import wraps
@@ -30,6 +32,24 @@
 _CONVERTER = JSONPlainPayloadConverter()
 
 
+def test_redis_asyncio_adapter_import_is_workflow_safe() -> None:
+    completed = subprocess.run(
+        [
+            sys.executable,
+            "-c",
+            (
+                "import sys; "
+                "import external_storage_redis.redis_asyncio; "
+                "print(any(name.startswith('redis.asyncio') for name in sys.modules))"
+            ),
+        ],
+        check=True,
+        capture_output=True,
+        text=True,
+    )
+    assert completed.stdout.strip() == "False"
+
+
 def make_payload(value: str = "hello") -> Payload:
     payload = _CONVERTER.to_payload(value)
     assert payload is not None