@@ -224,7 +224,7 @@ def request_handler(request: httpx.Request):
224224 return httpx .Response (200 , )
225225 return httpx .Response (
226226 TOO_MANY_REQUESTS ,
227- headers = {RETRY_AFTER : "200" }, # value exceeds max delay of 180 secs
227+ headers = {RETRY_AFTER : "200" }, # value exceeds max delay of 180 secs
228228 )
229229
230230 # Retry-after value takes precedence over the RetryHandlerOption value specified here
@@ -238,30 +238,30 @@ def request_handler(request: httpx.Request):
238238 assert resp .status_code == 429
239239 assert RETRY_ATTEMPT not in resp .request .headers
240240
241+
241242@pytest .mark .asyncio
242243async def test_max_retries_respected ():
243244 """Test that a request is not retried more than max_retries configured"""
244245
245246 def request_handler (request : httpx .Request ):
246247 if RETRY_ATTEMPT in request .headers :
247248 return httpx .Response (200 , )
248- return httpx .Response (
249- TOO_MANY_REQUESTS ,
250- )
249+ return httpx .Response (TOO_MANY_REQUESTS , )
251250
252251 # Retry-after value takes precedence over the RetryHandlerOption value specified here
253252 handler = RetryHandler (RetryHandlerOption (10 , 3 , True ))
254253 request = httpx .Request (
255254 'GET' ,
256255 BASE_URL ,
257- headers = {RETRY_ATTEMPT : '5' } # value exceeds max retries configured
256+ headers = {RETRY_ATTEMPT : '5' } # value exceeds max retries configured
258257 )
259258 mock_transport = httpx .MockTransport (request_handler )
260259 resp = await handler .send (request , mock_transport )
261260 assert resp .status_code == 200
262261 assert RETRY_ATTEMPT in resp .request .headers
263262 assert resp .request .headers [RETRY_ATTEMPT ] == '5'
264263
264+
265265@pytest .mark .asyncio
266266async def test_retry_options_apply_per_request ():
267267 """Test that a request options are applied per request"""
0 commit comments