From 772079fabd7453edf3788d0c31b9caf21ff5deca Mon Sep 17 00:00:00 2001 From: Milhan Date: Wed, 9 Nov 2022 21:22:05 +0900 Subject: Enable AsyncIO cluster mode lock (#2446) Co-authored-by: Chayim --- redis/commands/core.py | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) (limited to 'redis/commands/core.py') diff --git a/redis/commands/core.py b/redis/commands/core.py index c245a7a..3be2823 100644 --- a/redis/commands/core.py +++ b/redis/commands/core.py @@ -4930,7 +4930,11 @@ class Script: if isinstance(script, str): # We need the encoding from the client in order to generate an # accurate byte representation of the script - encoder = registered_client.connection_pool.get_encoder() + try: + encoder = registered_client.connection_pool.get_encoder() + except AttributeError: + # Cluster + encoder = registered_client.get_encoder() script = encoder.encode(script) self.sha = hashlib.sha1(script).hexdigest() @@ -4975,7 +4979,11 @@ class AsyncScript: if isinstance(script, str): # We need the encoding from the client in order to generate an # accurate byte representation of the script - encoder = registered_client.connection_pool.get_encoder() + try: + encoder = registered_client.connection_pool.get_encoder() + except AttributeError: + # Cluster + encoder = registered_client.get_encoder() script = encoder.encode(script) self.sha = hashlib.sha1(script).hexdigest() -- cgit v1.2.1