Fix #3290 missing parameter 'raise_for_status' for aiohttp.request() (#…

…3303)

CHANGES/3290.bugfix

@@ -0,0 +1 @@
+Fix missing parameter ``raise_for_status`` for aiohttp.request()

aiohttp/client.py

@@ -903,6 +903,7 @@ def request(method, url, *,
             compress=None,
             chunked=None,
             expect100=False,
+            raise_for_status=False,
             connector=None,
             loop=None,
             read_until_eof=True,
@@ -965,6 +966,7 @@ def request(method, url, *,
                          compress=compress,
                          chunked=chunked,
                          expect100=expect100,
+                         raise_for_status=raise_for_status,
                          read_until_eof=read_until_eof,
                          proxy=proxy,
                          proxy_auth=proxy_auth,),

tests/test_client_functional.py

@@ -2083,6 +2083,45 @@ async def handler_redirect(request):
     resp.close()
 
 
+async def test_request_raise_for_status_default(aiohttp_server) -> None:
+    async def handler(request):
+        raise web.HTTPBadRequest()
+
+    app = web.Application()
+    app.router.add_get('/', handler)
+    server = await aiohttp_server(app)
+
+    async with aiohttp.request('GET', server.make_url('/')) as resp:
+        assert resp.status == 400
+
+
+async def test_request_raise_for_status_disabled(aiohttp_server) -> None:
+    async def handler(request):
+        raise web.HTTPBadRequest()
+
+    app = web.Application()
+    app.router.add_get('/', handler)
+    server = await aiohttp_server(app)
+    url = server.make_url('/')
+
+    async with aiohttp.request('GET', url, raise_for_status=False) as resp:
+        assert resp.status == 400
+
+
+async def test_request_raise_for_status_enabled(aiohttp_server) -> None:
+    async def handler(request):
+        raise web.HTTPBadRequest()
+
+    app = web.Application()
+    app.router.add_get('/', handler)
+    server = await aiohttp_server(app)
+    url = server.make_url('/')
+
+    with pytest.raises(aiohttp.ClientResponseError):
+        async with aiohttp.request('GET', url, raise_for_status=True):
+            assert False, "never executed"  # pragma: no cover
+
+
 async def test_invalid_idna() -> None:
     session = aiohttp.ClientSession()
     try: