fix: use redis_url fixture in warning tests for CI compatibility

- Replace direct Redis connection with redis_url fixture
- Use AsyncRedis.from_url() instead of RedisConnectionFactory
- Add proper try/finally blocks for client cleanup
- Follow established test patterns from test_embedcache.py

This fixes 'Event loop is closed' errors in CI by using the same
Docker container-based Redis connection that other tests use.

Author: bsbodden

tests/integration/test_embedcache_warnings.py

@@ -1,26 +1,23 @@
 """Test warning behavior when using sync methods with async-only client."""
 
-import asyncio
 import logging
 from unittest.mock import patch
 
 import pytest
 from redis import Redis
+from redis.asyncio import Redis as AsyncRedis
 
 from redisvl.extensions.cache.embeddings import EmbeddingsCache
-from redisvl.redis.connection import RedisConnectionFactory
 
 
 @pytest.mark.asyncio
-async def test_sync_methods_warn_with_async_only_client(caplog):
+async def test_sync_methods_warn_with_async_only_client(redis_url, caplog):
     """Test that sync methods warn when only async client is provided."""
     # Reset the warning flag for testing
     EmbeddingsCache._warning_shown = False
 
-    # Create async redis client using the async method
-    async_client = await RedisConnectionFactory._get_aredis_connection(
-        "redis://localhost:6379"
-    )
+    # Create async redis client from the redis_url
+    async_client = await AsyncRedis.from_url(redis_url)
 
     try:
         # Initialize EmbeddingsCache with only async_redis_client
@@ -51,38 +48,37 @@ async def test_sync_methods_warn_with_async_only_client(caplog):
         await async_client.aclose()
 
 
-def test_no_warning_with_sync_client():
+def test_no_warning_with_sync_client(redis_url):
     """Test that no warning is shown when sync client is provided."""
     # Reset the warning flag for testing
     EmbeddingsCache._warning_shown = False
 
-    # Create sync redis client
-    sync_client = Redis.from_url("redis://localhost:6379")
+    # Create sync redis client from redis_url
+    sync_client = Redis.from_url(redis_url)
 
-    # Initialize EmbeddingsCache with sync_redis_client
-    cache = EmbeddingsCache(name="test_cache", redis_client=sync_client)
-
-    with patch("redisvl.utils.log.get_logger") as mock_logger:
-        # Sync methods should not warn
-        _ = cache.get_by_key("test_key")
-        _ = cache.set(text="test", model_name="model", embedding=[0.1, 0.2])
+    try:
+        # Initialize EmbeddingsCache with sync_redis_client
+        cache = EmbeddingsCache(name="test_cache", redis_client=sync_client)
 
-        # No warnings should have been logged
-        mock_logger.return_value.warning.assert_not_called()
+        with patch("redisvl.utils.log.get_logger") as mock_logger:
+            # Sync methods should not warn
+            _ = cache.get_by_key("test_key")
+            _ = cache.set(text="test", model_name="model", embedding=[0.1, 0.2])
 
-    sync_client.close()
+            # No warnings should have been logged
+            mock_logger.return_value.warning.assert_not_called()
+    finally:
+        sync_client.close()
 
 
 @pytest.mark.asyncio
-async def test_async_methods_no_warning():
+async def test_async_methods_no_warning(redis_url):
     """Test that async methods don't trigger warnings."""
     # Reset the warning flag for testing
     EmbeddingsCache._warning_shown = False
 
-    # Create async redis client using the async method
-    async_client = await RedisConnectionFactory._get_aredis_connection(
-        "redis://localhost:6379"
-    )
+    # Create async redis client from redis_url
+    async_client = await AsyncRedis.from_url(redis_url)
 
     try:
         # Initialize EmbeddingsCache with only async_redis_client