Deprecate .loop property

CHANGES/3374.removal

@@ -0,0 +1 @@
+Deprecate ``app.loop``, ``request.loop``, ``client.loop`` and ``connector.loop`` properties.

aiohttp/client.py

@@ -836,6 +836,9 @@ def version(self) -> Tuple[int, int]:
     @property
     def loop(self) -> asyncio.AbstractEventLoop:
         """Session's loop."""
+        warnings.warn("client.loop property is deprecated",
+                      DeprecationWarning,
+                      stacklevel=2)
         return self._loop
 
     def detach(self) -> None:

aiohttp/connector.py

@@ -94,6 +94,9 @@ def __del__(self, _warnings: Any=warnings) -> None:
 
     @property
     def loop(self) -> asyncio.AbstractEventLoop:
+        warnings.warn("connector.loop property is deprecated",
+                      DeprecationWarning,
+                      stacklevel=2)
         return self._loop
 
     @property

aiohttp/web_app.py

@@ -159,6 +159,9 @@ def loop(self) -> asyncio.AbstractEventLoop:
         # Technically the loop can be None
         # but we mask it by explicit type cast
         # to provide more convinient type annotation
+        warnings.warn("loop property is deprecated",
+                      DeprecationWarning,
+                      stacklevel=2)
         return cast(asyncio.AbstractEventLoop, self._loop)
 
     def _set_loop(self, loop: Optional[asyncio.AbstractEventLoop]) -> None:
@@ -331,7 +334,7 @@ def _make_handler(self, *,
 
         return Server(self._handle,  # type: ignore
                       request_factory=self._make_request,
-                      loop=self.loop, **kwargs)
+                      loop=self._loop, **kwargs)
 
     def make_handler(self, *,
                      loop: Optional[asyncio.AbstractEventLoop]=None,

aiohttp/web_fileresponse.py

@@ -139,7 +139,7 @@ async def _sendfile_system(self, request: 'BaseRequest',
         else:
             writer = SendfileStreamWriter(
                 request.protocol,
-                request.loop
+                request._loop
             )
             request._payload_writer = writer
 

aiohttp/web_request.py

@@ -212,6 +212,9 @@ def rel_url(self) -> URL:
 
     @reify
     def loop(self) -> asyncio.AbstractEventLoop:
+        warnings.warn("request.loop property is deprecated",
+                      DeprecationWarning,
+                      stacklevel=2)
         return self._loop
 
     # MutableMapping API

aiohttp/web_ws.py

@@ -194,7 +194,7 @@ def _handshake(self, request: BaseRequest) -> Tuple['CIMultiDict[str]',
                 notakeover)
 
     def _pre_start(self, request: BaseRequest) -> Tuple[str, WebSocketWriter]:
-        self._loop = request.loop
+        self._loop = request._loop
 
         headers, protocol, compress, notakeover = self._handshake(
             request)

tests/test_client_connection.py

@@ -33,7 +33,8 @@ def protocol():
 
 def test_ctor(connector, key, protocol, loop) -> None:
     conn = Connection(connector, key, protocol, loop)
-    assert conn.loop is loop
+    with pytest.warns(DeprecationWarning):
+        assert conn.loop is loop
     assert conn.protocol is protocol
     conn.close()
 

tests/test_client_functional.py

@@ -772,7 +772,7 @@ async def handler(request):
     app = web.Application()
     for meth in ('get', 'post', 'put', 'delete', 'head'):
         app.router.add_route(meth.upper(), '/', handler)
-    client = await aiohttp_client(app, connector=conn, conn_timeout=0.2)
+    client = await aiohttp_client(app, connector=conn)
 
     for meth in ('get', 'post', 'put', 'delete', 'head'):
         resp = await client.request(meth, '/')

tests/test_client_session.py

@@ -475,7 +475,8 @@ async def test_session_default_version(loop) -> None:
 
 async def test_session_loop(loop) -> None:
     session = aiohttp.ClientSession(loop=loop)
-    assert session.loop is loop
+    with pytest.warns(DeprecationWarning):
+        assert session.loop is loop
     await session.close()
 
 

tests/test_loop.py

@@ -25,11 +25,11 @@ async def get_application(self):
         return app
 
     async def on_startup_hook(self, app):
-        self.startup_loop = app.loop
+        self.on_startup_called = True
 
     @unittest_run_loop
     async def test_on_startup_hook(self) -> None:
-        self.assertIsNotNone(self.startup_loop)
+        self.assertTrue(self.on_startup_called)
 
     def test_default_loop(self) -> None:
         self.assertIs(self.loop, asyncio.get_event_loop())

tests/test_web_app.py

@@ -14,7 +14,8 @@ async def test_app_ctor() -> None:
     loop = asyncio.get_event_loop()
     with pytest.warns(DeprecationWarning):
         app = web.Application(loop=loop)
-    assert loop is app.loop
+    with pytest.warns(DeprecationWarning):
+        assert loop is app.loop
     assert app.logger is log.web_logger
 
 
@@ -25,30 +26,34 @@ def test_app_call() -> None:
 
 def test_app_default_loop() -> None:
     app = web.Application()
-    assert app.loop is None
+    with pytest.warns(DeprecationWarning):
+        assert app.loop is None
 
 
 async def test_set_loop() -> None:
     loop = asyncio.get_event_loop()
     app = web.Application()
     app._set_loop(loop)
-    assert app.loop is loop
+    with pytest.warns(DeprecationWarning):
+        assert app.loop is loop
 
 
 def test_set_loop_default_loop() -> None:
     loop = asyncio.new_event_loop()
     asyncio.set_event_loop(loop)
     app = web.Application()
     app._set_loop(None)
-    assert app.loop is loop
+    with pytest.warns(DeprecationWarning):
+        assert app.loop is loop
     asyncio.set_event_loop(None)
 
 
 def test_set_loop_with_different_loops() -> None:
     loop = asyncio.new_event_loop()
     app = web.Application()
     app._set_loop(loop)
-    assert app.loop is loop
+    with pytest.warns(DeprecationWarning):
+        assert app.loop is loop
 
     with pytest.raises(RuntimeError):
         app._set_loop(loop=object())

tests/test_web_request.py

@@ -1,3 +1,4 @@
+import asyncio
 import socket
 from collections.abc import MutableMapping
 from unittest import mock
@@ -655,3 +656,10 @@ def test_eq() -> None:
     req2 = make_mocked_request('GET', '/path/to?a=1&b=2')
     assert req1 != req2
     assert req1 == req1
+
+
+async def test_loop_prop() -> None:
+    loop = asyncio.get_event_loop()
+    req = make_mocked_request('GET', '/path', loop=loop)
+    with pytest.warns(DeprecationWarning):
+        assert req.loop is loop