Transport.perform_request mutate headers. (#694)

elastic · Jan 1, 2018 · 920218d · 920218d
1 parent a023bdd
commit 920218d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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):