call extra api with headers included (#40)

Revolution1 · Nov 17, 2018 · 04253c6 · 04253c6
1 parent cbcff39
commit 04253c6
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/etcd3/apis/extra.py b/etcd3/apis/extra.py
@@ -14,7 +14,7 @@ def version(self):
 
         :return: EtcdVersion
         """
-        resp = self._get(self._url('/version'))
+        resp = self._get(self._url('/version'), headers=self.headers)
         self._raise_for_status(resp)
         return EtcdVersion(**resp.json())
 
@@ -24,7 +24,7 @@ def health(self):
 
         :return: EtcdVersion
         """
-        resp = self._get(self._url('/health'))
+        resp = self._get(self._url('/health'), headers=self.headers)
         self._raise_for_status(resp)
         return resp.json()['health']
 
@@ -34,7 +34,7 @@ def metrics_raw(self):  # pragma: no cover
 
         :return: str
         """
-        resp = self._get(self._url('/metrics'))
+        resp = self._get(self._url('/metrics'), headers=self.headers)
         self._raise_for_status(resp)
         metrics = resp.content
         if not isinstance(metrics, six.text_type):

diff --git a/etcd3/baseclient.py b/etcd3/baseclient.py
@@ -78,7 +78,8 @@ def _retrieve_version(self):  # pragma: no cover
         try:
             import requests
 
-            r = requests.get(self._url('/version'), cert=self.cert, verify=self.verify, timeout=0.3)  # 300ms will do
+            r = requests.get(self._url('/version'), cert=self.cert,
+                    verify=self.verify, timeout=0.3, headers=self.headers)  # 300ms will do
             r.raise_for_status()
             v = r.json()
             self.cluster_version = v["etcdcluster"]