File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -400,7 +400,9 @@ def validate_sync_redis(
400
400
redis_client .client_setinfo ("LIB-NAME" , _lib_name )
401
401
except ResponseError :
402
402
# Fall back to a simple log echo
403
- redis_client .echo (_lib_name )
403
+ # For RedisCluster, echo is not available
404
+ if hasattr (redis_client , "echo" ):
405
+ await redis_client .echo (_lib_name )
404
406
405
407
# Get list of modules
406
408
installed_modules = RedisConnectionFactory .get_modules (redis_client )
@@ -426,6 +428,8 @@ async def validate_async_redis(
426
428
except ResponseError :
427
429
# Fall back to a simple log echo
428
430
await redis_client .echo (_lib_name )
431
+ if hasattr (redis_client , "echo" ):
432
+ await redis_client .echo (_lib_name )
429
433
430
434
# Get list of modules
431
435
installed_modules = await RedisConnectionFactory .get_modules_async (redis_client )
You can’t perform that action at this time.
0 commit comments