@@ -104,28 +104,30 @@ def _request_handler(context):
104104 else :
105105 cert = None
106106
107- retries = Retry (
108- total = context .get ("max_retries" , MAX_REQUEST_RETRIES ),
109- backoff_factor = 0.3 ,
110- status_forcelist = context .get ("retry_status_codes" , [500 , 502 , 503 , 504 ]),
111- allowed_methods = ["GET" , "POST" , "PUT" , "DELETE" ],
112- raise_on_status = False ,
113- )
107+ def adapter ():
108+ retries = Retry (
109+ total = context .get ("max_retries" , MAX_REQUEST_RETRIES ),
110+ backoff_factor = 0.3 ,
111+ status_forcelist = context .get ("retry_status_codes" , [500 , 502 , 503 , 504 ]),
112+ allowed_methods = ["GET" , "POST" , "PUT" , "DELETE" ],
113+ raise_on_status = False ,
114+ )
114115
115- adapter_args = {
116- "max_retries" : retries ,
117- }
116+ adapter_args = {
117+ "max_retries" : retries ,
118+ }
119+
120+ # By default, pool_connections and pool_maxsize are set to 10 in urllib3
121+ if "pool_connections" in context :
122+ adapter_args ["pool_connections" ] = context ["pool_connections" ]
123+ if "pool_maxsize" in context :
124+ adapter_args ["pool_maxsize" ] = context ["pool_maxsize" ]
118125
119- # By default, pool_connections and pool_maxsize are set to 10 in urllib3
120- if "pool_connections" in context :
121- adapter_args ["pool_connections" ] = context ["pool_connections" ]
122- if "pool_maxsize" in context :
123- adapter_args ["pool_maxsize" ] = context ["pool_maxsize" ]
126+ return requests .adapters .HTTPAdapter (** adapter_args )
124127
125128 session = requests .Session ()
126- adapter = requests .adapters .HTTPAdapter (** adapter_args )
127- session .mount ("http://" , adapter )
128- session .mount ("https://" , adapter )
129+ session .mount ("http://" , adapter ())
130+ session .mount ("https://" , adapter ())
129131
130132 req_func = session .request
131133
0 commit comments