1
1
"""Tests for the HTTP server."""
2
2
3
- from http import HTTPStatus
4
3
import os
5
4
import queue
6
5
import socket
9
8
import types
10
9
import urllib .parse # noqa: WPS301
11
10
import uuid
11
+ from http import HTTPStatus
12
12
13
13
import pytest
14
14
@@ -575,15 +575,18 @@ def test_threadpool_multistart_validation(monkeypatch):
575
575
576
576
def test_overload_results_in_suitable_http_error (request ):
577
577
"""A server that can't keep up with requests returns a 503 HTTP error."""
578
- localhost = " 127.0.0.1"
578
+ localhost = ' 127.0.0.1'
579
579
httpserver = HTTPServer (
580
580
bind_addr = (localhost , EPHEMERAL_PORT ),
581
- gateway = Gateway
581
+ gateway = Gateway ,
582
582
)
583
583
# Can only handle on request in parallel:
584
584
httpserver .requests = ThreadPool (
585
- min = 1 , max = 1 , accepted_queue_size = 1 ,
586
- accepted_queue_timeout = 0 , server = httpserver
585
+ min = 1 ,
586
+ max = 1 ,
587
+ accepted_queue_size = 1 ,
588
+ accepted_queue_timeout = 0 ,
589
+ server = httpserver ,
587
590
)
588
591
589
592
httpserver .prepare ()
@@ -599,5 +602,5 @@ def test_overload_results_in_suitable_http_error(request):
599
602
# requests fail:
600
603
httpserver .requests ._queue .put (None )
601
604
602
- response = requests .get (f" http://127.0.0.1:{ port } " , timeout = 5 )
605
+ response = requests .get (f' http://127.0.0.1:{ port } ' , timeout = 5 )
603
606
assert response .status_code == HTTPStatus .SERVICE_UNAVAILABLE .value
0 commit comments