diff options
author | rafie <rafi@redislabs.com> | 2021-11-28 14:35:19 +0200 |
---|---|---|
committer | rafie <rafi@redislabs.com> | 2021-11-28 14:35:19 +0200 |
commit | b3a1468bc82253a65abc5d00dad2850a8dbe2868 (patch) | |
tree | e1e346ab24655c7d20643932a784fce9326d9efa | |
parent | bab95011b2681e90560715b2607f37cc5b1ea156 (diff) | |
download | redis-py-b3a1468bc82253a65abc5d00dad2850a8dbe2868.tar.gz |
fixes 2
-rwxr-xr-x | redis/client.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/redis/client.py b/redis/client.py index c458490..706299c 100755 --- a/redis/client.py +++ b/redis/client.py @@ -1092,7 +1092,8 @@ class Redis(RedisModuleCommands, CoreCommands, SentinelCommands, object): pool = self.connection_pool command_name = args[0] need_custom = options != {} and options.keys() != ['decode_responses'] - conn = self.connection and not need_custom or pool.get_connection(command_name, **options) + conn = self.connection and not need_custom or + pool.get_connection(command_name, **options) try: return conn.retry.call_with_retry( @@ -1109,7 +1110,8 @@ class Redis(RedisModuleCommands, CoreCommands, SentinelCommands, object): "Parses a response from the Redis server" try: if 'decode_responses' in options: - response = connection.read_response(decode_responses=options['decode_responses']) + response = connection.read_response(decode_responses= + options['decode_responses']) else: response = connection.read_response() except ResponseError: |