Skip to content

Commit f011d69

Browse files
committed
Respect session verify
1 parent 0015f81 commit f011d69

File tree

1 file changed

+12
-9
lines changed

1 file changed

+12
-9
lines changed

prometheus_api_client/prometheus_connect.py

Lines changed: 12 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,6 @@ def __init__(
6060
self.url = url
6161
self.prometheus_host = urlparse(self.url).netloc
6262
self._all_metrics = None
63-
self.ssl_verification = not disable_ssl
6463

6564
if retry is None:
6665
retry = Retry(
@@ -71,7 +70,11 @@ def __init__(
7170

7271
self.auth = auth
7372

74-
self._session = session if session is not None else requests.Session()
73+
if session is not None:
74+
self._session == session
75+
else:
76+
self._session = requests.Session()
77+
self._session.verify = not disable_ssl
7578

7679
if proxy is not None:
7780
self._session.proxies = proxy
@@ -87,7 +90,7 @@ def check_prometheus_connection(self, params: dict = None) -> bool:
8790
"""
8891
response = self._session.get(
8992
"{0}/".format(self.url),
90-
verify=self.ssl_verification,
93+
verify=self._session.verify,
9194
headers=self.headers,
9295
params=params,
9396
auth=self.auth,
@@ -124,7 +127,7 @@ def get_label_names(self, params: dict = None):
124127
params = params or {}
125128
response = self._session.get(
126129
"{0}/api/v1/labels".format(self.url),
127-
verify=self.ssl_verification,
130+
verify=self._session.verify,
128131
headers=self.headers,
129132
params=params,
130133
auth=self.auth,
@@ -154,7 +157,7 @@ def get_label_values(self, label_name: str, params: dict = None):
154157
params = params or {}
155158
response = self._session.get(
156159
"{0}/api/v1/label/{1}/values".format(self.url, label_name),
157-
verify=self.ssl_verification,
160+
verify=self._session.verify,
158161
headers=self.headers,
159162
params=params,
160163
auth=self.auth,
@@ -206,7 +209,7 @@ def get_current_metric_value(
206209
response = self._session.get(
207210
"{0}/api/v1/query".format(self.url),
208211
params={**{"query": query}, **params},
209-
verify=self.ssl_verification,
212+
verify=self._session.verify,
210213
headers=self.headers,
211214
auth=self.auth,
212215
cert=self._session.cert
@@ -298,7 +301,7 @@ def get_metric_range_data(
298301
},
299302
**params,
300303
},
301-
verify=self.ssl_verification,
304+
verify=self._session.verify,
302305
headers=self.headers,
303306
auth=self.auth,
304307
cert=self._session.cert
@@ -397,7 +400,7 @@ def custom_query(self, query: str, params: dict = None):
397400
response = self._session.get(
398401
"{0}/api/v1/query".format(self.url),
399402
params={**{"query": query}, **params},
400-
verify=self.ssl_verification,
403+
verify=self._session.verify,
401404
headers=self.headers,
402405
auth=self.auth,
403406
cert=self._session.cert
@@ -441,7 +444,7 @@ def custom_query_range(
441444
response = self._session.get(
442445
"{0}/api/v1/query_range".format(self.url),
443446
params={**{"query": query, "start": start, "end": end, "step": step}, **params},
444-
verify=self.ssl_verification,
447+
verify=self._session.verify,
445448
headers=self.headers,
446449
auth=self.auth,
447450
cert=self._session.cert

0 commit comments

Comments
 (0)