Debug

Author: ianthomas23

pyproject.toml

@@ -95,13 +95,13 @@ api = "sphinx-apidoc -o docs/api -f -E ipykernel tests ipykernel/datapub.py ipyk
 features = ["test"]
 [tool.hatch.envs.test.scripts]
 list = "python -m pip freeze"
-test = "python -m pytest -vv {args}"
+test = "python -m pytest -xvvrP {args}"
 nowarn = "test -W default {args}"
 
 [tool.hatch.envs.cov]
 features = ["test", "cov"]
 [tool.hatch.envs.cov.scripts]
-test = "python -m pytest -vv --cov ipykernel --cov-branch --cov-report term-missing:skip-covered {args}"
+test = "python -m pytest -xvvrP --cov ipykernel --cov-branch --cov-report term-missing:skip-covered {args}"
 nowarn = "test -W default {args}"
 
 [[tool.hatch.envs.cov.matrix]]
@@ -158,7 +158,7 @@ testpaths = [
     "tests",
 ]
 asyncio_mode = "auto"
-timeout = 300
+timeout = 10
 # Restore this setting to debug failures
 #timeout_method = "thread"
 filterwarnings= [

tests/test_subshells.py

@@ -127,9 +127,10 @@ def test_run_concurrently_sequence(are_subshells, overlap, request):
 
         # Import time module before running time-sensitive subshell code
         # and use threading.Barrier to synchronise start of subshell code.
-        execute_request_subshell_id(
+        msg = execute_request(
             kc, "import threading as t, time; b=t.Barrier(2); print('ok')", None
         )
+        get_reply(kc, msg["msg_id"])
 
         sleep = 0.5
         if overlap:
@@ -150,7 +151,9 @@ def test_run_concurrently_sequence(are_subshells, overlap, request):
             kc.shell_channel.send(msg)
             msgs.append(msg)
 
+        print("XXX before replies")
         replies = get_replies(kc, [msg["msg_id"] for msg in msgs], timeout=None)
+        print("XXX after replies", len(replies))
 
         for subshell_id in subshell_ids:
             if subshell_id:

tests/utils.py

@@ -71,6 +71,7 @@ def get_replies(kc, msg_ids: list[str], timeout=TIMEOUT, channel="shell"):
     while count < len(msg_ids):
         get_msg = getattr(kc, f"get_{channel}_msg")
         reply = get_msg(timeout=timeout)
+        print("XXX reply", reply)
         try:
             msg_id = reply["parent_header"]["msg_id"]
             replies[msg_ids.index(msg_id)] = reply