diff --git a/redis/client.py b/redis/client.py index abbb2d6ab2..496e28f097 100644 --- a/redis/client.py +++ b/redis/client.py @@ -258,17 +258,15 @@ def _execute_command(self, command_name, command, **options): "UNSUBSCRIBE while channels are open") try: self.connection.send(command, self) - response = self.parse_response(command_name, **options) if subscription_command: return None - return response + return self.parse_response(command_name, **options) except ConnectionError: self.connection.disconnect() self.connection.send(command, self) - response = self.parse_response(command_name, **options) if subscription_command: return None - return response + return self.parse_response(command_name, **options) def execute_command(self, *args, **options): "Sends the command to the redis server and returns it's response"