Delete always skipped tests that used removed attributes

And try to fix trio tests

Author: Carreau

ipykernel/kernelapp.py

@@ -730,15 +730,23 @@ def initialize(self, argv=None):
         sys.stdout.flush()
         sys.stderr.flush()
 
-    def start(self) -> None:
-        """Start the application."""
+    async def _start(self) -> None:
+        """
+        Async version of start, when the loop is not controlled by IPykernel
+
+        For example to be used in test suite with @pytest.mark.trio
+        """
         if self.subapp is not None:
             self.subapp.start()
-            return
+            return None
         if self.poller is not None:
             self.poller.start()
+        return await self.main()
+
+    def start(self) -> None:
+        """Start the application."""
         backend = "trio" if self.trio_loop else "asyncio"
-        run(self.main, backend=backend)
+        run(self._start, backend=backend)
         return
 
     async def _wait_to_enter_eventloop(self):

pyproject.toml

@@ -54,14 +54,15 @@ docs = [
   "trio"
 ]
 test = [
-    "pytest>=7.0,<9",
-    "pytest-cov",
     "flaky",
     "ipyparallel",
     "pre-commit",
+    "pytest-asyncio>=0.23.5",
+    "pytest-cov",
     "pytest-timeout",
+    "anyio[trio]",
+    "pytest>=7.0,<9",
     "trio",
-    "pytest-asyncio>=0.23.5",
 ]
 cov = [
   "coverage[toml]",

tests/test_ipkernel_direct.py

@@ -1,6 +1,5 @@
 """Test IPythonKernel directly"""
 
-import asyncio
 import os
 
 import pytest
@@ -152,49 +151,12 @@ async def test_direct_clear(ipkernel):
     ipkernel.do_clear()
 
 
-@pytest.mark.skip("ipykernel._cancel_on_sigint doesn't exist anymore")
-async def test_cancel_on_sigint(ipkernel: IPythonKernel) -> None:
-    future: asyncio.Future = asyncio.Future()
-    # with ipkernel._cancel_on_sigint(future):
-    #     pass
-    future.set_result(None)
-
-
 async def test_dispatch_debugpy(ipkernel: IPythonKernel) -> None:
     msg = ipkernel.session.msg("debug_request", {})
     msg_list = ipkernel.session.serialize(msg)
     await ipkernel.receive_debugpy_message(msg_list)
 
 
-@pytest.mark.skip("Queues don't exist anymore")
-async def test_start(ipkernel: IPythonKernel) -> None:
-    shell_future: asyncio.Future = asyncio.Future()
-
-    async def fake_dispatch_queue():
-        shell_future.set_result(None)
-
-    ipkernel.dispatch_queue = fake_dispatch_queue  # type:ignore
-    ipkernel.start()
-    ipkernel.debugpy_stream = None
-    ipkernel.start()
-    await ipkernel.process_one(False)
-    await shell_future
-
-
-@pytest.mark.skip("Queues don't exist anymore")
-async def test_start_no_debugpy(ipkernel: IPythonKernel) -> None:
-    shell_future: asyncio.Future = asyncio.Future()
-
-    async def fake_dispatch_queue():
-        shell_future.set_result(None)
-
-    ipkernel.dispatch_queue = fake_dispatch_queue  # type:ignore
-    ipkernel.debugpy_stream = None
-    ipkernel.start()
-
-    await shell_future
-
-
 def test_create_comm():
     assert isinstance(_create_comm(), BaseComm)
 

tests/test_kernel_direct.py

@@ -3,9 +3,7 @@
 # Copyright (c) IPython Development Team.
 # Distributed under the terms of the Modified BSD License.
 
-import asyncio
 import os
-import warnings
 
 import pytest
 
@@ -108,19 +106,6 @@ async def test_direct_debug_request(kernel):
     assert reply["header"]["msg_type"] == "debug_reply"
 
 
-@pytest.mark.skip("Shell streams don't exist anymore")
-async def test_deprecated_features(kernel):
-    with warnings.catch_warnings():
-        warnings.simplefilter("ignore", DeprecationWarning)
-        header = kernel._parent_header
-        assert isinstance(header, dict)
-        shell_streams = kernel.shell_streams
-        assert len(shell_streams) == 1
-        assert shell_streams[0] == kernel.shell_stream
-        warnings.simplefilter("ignore", RuntimeWarning)
-        kernel.shell_streams = [kernel.shell_stream, kernel.shell_stream]
-
-
 async def test_process_control(kernel):
     from jupyter_client.session import DELIM
 
@@ -142,12 +127,6 @@ async def test_dispatch_shell(kernel):
     await kernel.process_shell_message(msg)
 
 
-@pytest.mark.skip("kernelbase.do_one_iteration doesn't exist anymore")
-async def test_do_one_iteration(kernel):
-    kernel.msg_queue = asyncio.Queue()
-    await kernel.do_one_iteration()
-
-
 async def test_publish_debug_event(kernel):
     kernel._publish_debug_event({})
 
@@ -160,7 +139,7 @@ async def test_send_interrupt_children(kernel):
     kernel._send_interrupt_children()
 
 
-# TODO: this causes deadlock
-# async def test_direct_usage_request(kernel):
-#     reply = await kernel.test_control_message("usage_request", {})
-#     assert reply['header']['msg_type'] == 'usage_reply'
+@pytest.mark.skip(reason="this causes deadlock")
+async def test_direct_usage_request(kernel):
+    reply = await kernel.test_control_message("usage_request", {})
+    assert reply["header"]["msg_type"] == "usage_reply"

tests/test_kernelapp.py

@@ -12,11 +12,6 @@
 from .conftest import MockKernel
 from .utils import TemporaryWorkingDirectory
 
-try:
-    import trio
-except ImportError:
-    trio = None
-
 
 @pytest.mark.skipif(os.name == "nt", reason="requires ipc")
 def test_init_ipc_socket():
@@ -117,21 +112,22 @@ def test_merge_connection_file():
         os.remove(cf)
 
 
-# FIXME: @pytest.mark.skipif(trio is None, reason="requires trio")
-@pytest.mark.skip()
-def test_trio_loop():
+@pytest.mark.skip("Something wrong with CI")
+@pytest.mark.parametrize("anyio_backend", ["trio"])
+async def test_trio_loop(anyio_backend):
+    import trio
+
     app = IPKernelApp(trio_loop=True)
 
-    def trigger_stop():
-        time.sleep(1)
+    async def trigger_stop():
+        await trio.sleep(1)
         app.stop()
 
-    thread = threading.Thread(target=trigger_stop)
-    thread.start()
-
     app.kernel = MockKernel()
     app.init_sockets()
-    app.start()
+    async with trio.open_nursery() as nursery:
+        nursery.start_soon(app._start)
+        nursery.start_soon(trigger_stop)
     app.cleanup_connection_file()
     app.kernel.destroy()
     app.close()