Use default required mods unless needing introspection

Author: abrookins

redisvl/index/index.py

@@ -1,12 +1,8 @@
 import asyncio
 import json
-import logging
 import threading
 import warnings
 import weakref
-from functools import wraps
-from os import replace
-from re import S
 from typing import (
     TYPE_CHECKING,
     Any,
@@ -47,6 +43,12 @@
 logger = get_logger(__name__)
 
 
+REQUIRED_MODULES_FOR_INTROSPECTION = [
+    {"name": "search", "ver": 20810},
+    {"name": "searchlight", "ver": 20810},
+]
+
+
 def process_results(
     results: "Result", query: BaseQuery, storage_type: StorageType
 ) -> List[Dict[str, Any]]:
@@ -242,11 +244,6 @@ class SearchIndex(BaseSearchIndex):
 
     """
 
-    required_modules = [
-        {"name": "search", "ver": 20810},
-        {"name": "searchlight", "ver": 20810},
-    ]
-
     @deprecated_argument("connection_args", "Use connection_kwargs instead.")
     def __init__(
         self,
@@ -324,12 +321,12 @@ def from_existing(
             if redis_url:
                 redis_client = RedisConnectionFactory.get_redis_connection(
                     redis_url=redis_url,
-                    required_modules=cls.required_modules,
+                    required_modules=REQUIRED_MODULES_FOR_INTROSPECTION,
                     **kwargs,
                 )
             elif redis_client:
                 RedisConnectionFactory.validate_sync_redis(
-                    redis_client, required_modules=cls.required_modules
+                    redis_client, required_modules=REQUIRED_MODULES_FOR_INTROSPECTION
                 )
         except RedisModuleVersionError as e:
             raise RedisModuleVersionError(
@@ -829,11 +826,6 @@ class AsyncSearchIndex(BaseSearchIndex):
 
     """
 
-    required_modules = [
-        {"name": "search", "ver": 20810},
-        {"name": "searchlight", "ver": 20810},
-    ]
-
     @deprecated_argument("redis_kwargs", "Use connection_kwargs instead.")
     def __init__(
         self,
@@ -902,11 +894,13 @@ async def from_existing(
         try:
             if redis_url:
                 redis_client = await RedisConnectionFactory._get_aredis_connection(
-                    url=redis_url, required_modules=cls.required_modules, **kwargs
+                    url=redis_url,
+                    required_modules=REQUIRED_MODULES_FOR_INTROSPECTION,
+                    **kwargs,
                 )
             elif redis_client:
                 await RedisConnectionFactory.validate_async_redis(
-                    redis_client, required_modules=cls.required_modules
+                    redis_client, required_modules=REQUIRED_MODULES_FOR_INTROSPECTION
                 )
         except RedisModuleVersionError as e:
             raise RedisModuleVersionError(

redisvl/utils/utils.py

@@ -13,8 +13,6 @@
 from pydantic import BaseModel
 from ulid import ULID
 
-from redisvl.utils.log import get_logger
-
 
 def create_ulid() -> str:
     """Generate a unique identifier to group related Redis documents."""
@@ -157,6 +155,7 @@ def decorator(func):
 
         @wraps(func)
         def wrapper(*args, **kwargs):
+            print("???")
             warn(warning_message, category=DeprecationWarning, stacklevel=3)
             return func(*args, **kwargs)