Remove tokio support (#7281)

Project has been archived and was last updated 6 years ago. It's dead.

.mypy.ini

@@ -35,9 +35,6 @@ ignore_missing_imports = True
 [mypy-gunicorn.*]
 ignore_missing_imports = True
 
-[mypy-tokio]
-ignore_missing_imports = True
-
 [mypy-uvloop]
 ignore_missing_imports = True
 

CHANGES/7281.removal

@@ -0,0 +1 @@
+Removed support for unsupported ``tokio`` event loop -- by :user:`Dreamsorcerer`

aiohttp/pytest_plugin.py

@@ -24,11 +24,6 @@
 except ImportError:  # pragma: no cover
     uvloop = None
 
-try:
-    import tokio
-except ImportError:  # pragma: no cover
-    tokio = None
-
 AiohttpClient = Callable[[Union[Application, BaseTestServer]], Awaitable[TestClient]]
 
 
@@ -43,7 +38,7 @@ def pytest_addoption(parser):  # type: ignore[no-untyped-def]
         "--aiohttp-loop",
         action="store",
         default="pyloop",
-        help="run tests with specific loop: pyloop, uvloop, tokio or all",
+        help="run tests with specific loop: pyloop, uvloop or all",
     )
     parser.addoption(
         "--aiohttp-enable-loop-debug",
@@ -203,11 +198,8 @@ def pytest_generate_tests(metafunc):  # type: ignore[no-untyped-def]
     if uvloop is not None:  # pragma: no cover
         avail_factories["uvloop"] = uvloop.EventLoopPolicy
 
-    if tokio is not None:  # pragma: no cover
-        avail_factories["tokio"] = tokio.EventLoopPolicy
-
     if loops == "all":
-        loops = "pyloop,uvloop?,tokio?"
+        loops = "pyloop,uvloop?"
 
     factories = {}  # type: ignore[var-annotated]
     for name in loops.split(","):

aiohttp/worker.py

@@ -26,7 +26,7 @@
     SSLContext = object  # type: ignore[misc,assignment]
 
 
-__all__ = ("GunicornWebWorker", "GunicornUVLoopWebWorker", "GunicornTokioWebWorker")
+__all__ = ("GunicornWebWorker", "GunicornUVLoopWebWorker")
 
 
 class GunicornWebWorker(base.Worker):  # type: ignore[misc,no-any-unimported]
@@ -243,15 +243,3 @@ def init_process(self) -> None:
         asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
 
         super().init_process()
-
-
-class GunicornTokioWebWorker(GunicornWebWorker):
-    def init_process(self) -> None:  # pragma: no cover
-        import tokio
-
-        # Setup tokio policy, so that every
-        # asyncio.get_event_loop() will create an instance
-        # of tokio event loop.
-        asyncio.set_event_loop_policy(tokio.EventLoopPolicy())
-
-        super().init_process()

tests/test_run_app.py

@@ -55,20 +55,13 @@
         HAS_IPV6 = False
 
 
-# tokio event loop does not allow to override attributes
-def skip_if_no_dict(loop: Any) -> None:
-    if not hasattr(loop, "__dict__"):
-        pytest.skip("can not override loop attributes")
-
-
 def skip_if_on_windows() -> None:
     if platform.system() == "Windows":
         pytest.skip("the test is not valid for Windows")
 
 
 @pytest.fixture
 def patched_loop(loop: Any):
-    skip_if_no_dict(loop)
     server = mock.Mock()
     server.wait_closed = make_mocked_coro(None)
     loop.create_server = make_mocked_coro(server)

tests/test_worker.py

@@ -23,12 +23,6 @@
 ACCEPTABLE_LOG_FORMAT = '%a "%{Referrer}i" %s'
 
 
-# tokio event loop does not allow to override attributes
-def skip_if_no_dict(loop):
-    if not hasattr(loop, "__dict__"):
-        pytest.skip("can not override loop attributes")
-
-
 class BaseTestWorker:
     def __init__(self):
         self.servers = {}
@@ -200,8 +194,6 @@ def test__get_valid_log_format_exc(worker) -> None:
 
 
 async def test__run_ok_parent_changed(worker, loop, aiohttp_unused_port) -> None:
-    skip_if_no_dict(loop)
-
     worker.ppid = 0
     worker.alive = True
     sock = socket.socket()
@@ -221,8 +213,6 @@ async def test__run_ok_parent_changed(worker, loop, aiohttp_unused_port) -> None
 
 
 async def test__run_exc(worker, loop, aiohttp_unused_port) -> None:
-    skip_if_no_dict(loop)
-
     worker.ppid = os.getppid()
     worker.alive = True
     sock = socket.socket()