@@ -170,6 +170,7 @@ def __init__(self,
170
170
is_skipped_an_issue = True ,
171
171
verify_ssl = True ,
172
172
retries = None ,
173
+ max_pool_size = 50 ,
173
174
** kwargs ):
174
175
"""Init the service class.
175
176
@@ -182,6 +183,9 @@ def __init__(self,
182
183
is_skipped_an_issue: option to mark skipped tests as not
183
184
'To Investigate' items on Server side.
184
185
verify_ssl: option to not verify ssl certificates
186
+ max_pool_size: option to set the maximum number of
187
+ connections to save in the pool.
188
+
185
189
"""
186
190
self ._batch_logs = []
187
191
self .endpoint = endpoint
@@ -191,14 +195,13 @@ def __init__(self,
191
195
self .is_skipped_an_issue = is_skipped_an_issue
192
196
self .base_url_v1 = uri_join (self .endpoint , "api/v1" , self .project )
193
197
self .base_url_v2 = uri_join (self .endpoint , "api/v2" , self .project )
194
- self .max_pool_size = 50
195
198
196
199
self .session = requests .Session ()
197
200
if retries :
198
201
self .session .mount ('https://' , HTTPAdapter (
199
- max_retries = retries , pool_maxsize = self . max_pool_size ))
202
+ max_retries = retries , pool_maxsize = max_pool_size ))
200
203
self .session .mount ('http://' , HTTPAdapter (
201
- max_retries = retries , pool_maxsize = self . max_pool_size ))
204
+ max_retries = retries , pool_maxsize = max_pool_size ))
202
205
self .session .headers ["Authorization" ] = "bearer {0}" .format (self .token )
203
206
self .launch_id = None
204
207
self .verify_ssl = verify_ssl
0 commit comments