diff --git a/redisvl/redis/connection.py b/redisvl/redis/connection.py index 5ec562d0..4568b478 100644 --- a/redisvl/redis/connection.py +++ b/redisvl/redis/connection.py @@ -397,7 +397,9 @@ def validate_sync_redis( redis_client.client_setinfo("LIB-NAME", _lib_name) except ResponseError: # Fall back to a simple log echo - redis_client.echo(_lib_name) + # For RedisCluster, echo is not available + if hasattr(redis_client, "echo"): + await redis_client.echo(_lib_name) # Get list of modules installed_modules = RedisConnectionFactory.get_modules(redis_client) @@ -423,6 +425,8 @@ async def validate_async_redis( except ResponseError: # Fall back to a simple log echo await redis_client.echo(_lib_name) + if hasattr(redis_client, "echo"): + await redis_client.echo(_lib_name) # Get list of modules installed_modules = await RedisConnectionFactory.get_modules_async(redis_client)