@@ -304,7 +304,6 @@ def from_existing(
304304 name : str ,
305305 redis_client : Optional [redis .Redis ] = None ,
306306 redis_url : Optional [str ] = None ,
307- required_modules : Optional [List [Dict [str , Any ]]] = None ,
308307 ** kwargs ,
309308 ):
310309 """
@@ -316,8 +315,6 @@ def from_existing(
316315 instantiated redis client.
317316 redis_url (Optional[str]): The URL of the Redis server to
318317 connect to.
319- required_modules (Optional[List[Dict[str, Any]]]): List of required
320- Redis modules with version requirements.
321318
322319 Raises:
323320 ValueError: If redis_url or redis_client is not provided.
@@ -326,11 +323,13 @@ def from_existing(
326323 try :
327324 if redis_url :
328325 redis_client = RedisConnectionFactory .get_redis_connection (
329- redis_url = redis_url , required_modules = required_modules , ** kwargs
326+ redis_url = redis_url ,
327+ required_modules = cls .required_modules ,
328+ ** kwargs ,
330329 )
331330 elif redis_client :
332331 RedisConnectionFactory .validate_sync_redis (
333- redis_client , required_modules = required_modules
332+ redis_client , required_modules = cls . required_modules
334333 )
335334 except RedisModuleVersionError as e :
336335 raise RedisModuleVersionError (
0 commit comments