From 920218db835c9fcea63135d8bae00fb298b76fdb Mon Sep 17 00:00:00 2001 From: Fabrice Bacchella Date: Mon, 1 Jan 2018 15:54:09 +0100 Subject: [PATCH] Transport.perform_request mutate headers. (#694) --- elasticsearch/transport.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/elasticsearch/transport.py b/elasticsearch/transport.py index bf6768c69..e104d3875 100644 --- a/elasticsearch/transport.py +++ b/elasticsearch/transport.py @@ -311,7 +311,7 @@ def perform_request(self, method, url, headers=None, params=None, body=None): connection = self.get_connection() try: - status, headers, data = connection.perform_request(method, url, params, body, headers=headers, ignore=ignore, timeout=timeout) + status, headers_response, data = connection.perform_request(method, url, params, body, headers=headers, ignore=ignore, timeout=timeout) except TransportError as e: if method == 'HEAD' and e.status_code == 404: @@ -342,7 +342,7 @@ def perform_request(self, method, url, headers=None, params=None, body=None): return 200 <= status < 300 if data: - data = self.deserializer.loads(data, headers.get('content-type')) + data = self.deserializer.loads(data, headers_response.get('content-type')) return data def close(self):