fixes #2

Author: jph00

conkernelclient/core.py

@@ -38,7 +38,9 @@ async def start_channels(self, shell:bool=True, iopub:bool=True, stdin:bool=True
         super().start_channels(shell=shell, iopub=iopub, stdin=stdin, hb=hb, control=control)
         await self.wait_for_ready()
         self._pending = {}
+        _ready = asyncio.Event()
         async def _reader():
+            _ready.set()
             while True:
                 try: reply = await self.get_shell_msg(timeout=None)
                 except Exception as e:
@@ -47,6 +49,7 @@ async def _reader():
                 q = self._pending.get(reply["parent_header"].get("msg_id"))
                 if q: await q.put(reply)
         self._shell_reader_task = asyncio.create_task(_reader())
+        await _ready.wait()
         return self
 
     def stop_channels(self):

nbs/00_core.ipynb

@@ -103,7 +103,9 @@
     "        super().start_channels(shell=shell, iopub=iopub, stdin=stdin, hb=hb, control=control)\n",
     "        await self.wait_for_ready()\n",
     "        self._pending = {}\n",
+    "        _ready = asyncio.Event()\n",
     "        async def _reader():\n",
+    "            _ready.set()\n",
     "            while True:\n",
     "                try: reply = await self.get_shell_msg(timeout=None)\n",
     "                except Exception as e:\n",
@@ -112,6 +114,7 @@
     "                q = self._pending.get(reply[\"parent_header\"].get(\"msg_id\"))\n",
     "                if q: await q.put(reply)\n",
     "        self._shell_reader_task = asyncio.create_task(_reader())\n",
+    "        await _ready.wait()\n",
     "        return self\n",
     "\n",
     "    def stop_channels(self):\n",
@@ -211,7 +214,7 @@
     {
      "data": {
       "text/plain": [
-       "'3c390298-8280dc2636a968ecb67ec5c3_66839_1'"
+       "'a2d721a7-d3a69082190b8110efa35236_96513_1'"
       ]
      },
      "execution_count": null,
@@ -276,11 +279,11 @@
     {
      "data": {
       "text/plain": [
-       "{'msg_id': '3c390298-8280dc2636a968ecb67ec5c3_66839_1',\n",
+       "{'msg_id': 'a2d721a7-d3a69082190b8110efa35236_96513_1',\n",
        " 'msg_type': 'execute_request',\n",
        " 'username': 'jhoward',\n",
-       " 'session': '3c390298-8280dc2636a968ecb67ec5c3',\n",
-       " 'date': datetime.datetime(2026, 2, 25, 23, 47, 27, 999676, tzinfo=tzutc()),\n",
+       " 'session': 'a2d721a7-d3a69082190b8110efa35236',\n",
+       " 'date': datetime.datetime(2026, 2, 26, 22, 36, 10, 601820, tzinfo=tzutc()),\n",
        " 'version': '5.4'}"
       ]
      },
@@ -322,23 +325,23 @@
     {
      "data": {
       "text/plain": [
-       "{'header': {'msg_id': '56b3a92a-4ab2147e6a13d3987d1c6e81_66859_21',\n",
+       "{'header': {'msg_id': '27ce75ec-224d82ffa15cf1a4eebe62cd_96540_21',\n",
        "  'msg_type': 'execute_reply',\n",
        "  'username': 'jhoward',\n",
-       "  'session': '56b3a92a-4ab2147e6a13d3987d1c6e81',\n",
-       "  'date': datetime.datetime(2026, 2, 25, 23, 47, 28, 524193, tzinfo=tzutc()),\n",
+       "  'session': '27ce75ec-224d82ffa15cf1a4eebe62cd',\n",
+       "  'date': datetime.datetime(2026, 2, 26, 22, 36, 11, 126459, tzinfo=tzutc()),\n",
        "  'version': '5.4'},\n",
-       " 'msg_id': '56b3a92a-4ab2147e6a13d3987d1c6e81_66859_21',\n",
+       " 'msg_id': '27ce75ec-224d82ffa15cf1a4eebe62cd_96540_21',\n",
        " 'msg_type': 'execute_reply',\n",
-       " 'parent_header': {'msg_id': '3c390298-8280dc2636a968ecb67ec5c3_66839_1',\n",
+       " 'parent_header': {'msg_id': 'a2d721a7-d3a69082190b8110efa35236_96513_1',\n",
        "  'msg_type': 'execute_request',\n",
        "  'username': 'jhoward',\n",
-       "  'session': '3c390298-8280dc2636a968ecb67ec5c3',\n",
-       "  'date': datetime.datetime(2026, 2, 25, 23, 47, 28, 521117, tzinfo=tzutc()),\n",
+       "  'session': 'a2d721a7-d3a69082190b8110efa35236',\n",
+       "  'date': datetime.datetime(2026, 2, 26, 22, 36, 11, 123474, tzinfo=tzutc()),\n",
        "  'version': '5.4'},\n",
-       " 'metadata': {'started': '2026-02-25T23:47:28.522179Z',\n",
+       " 'metadata': {'started': '2026-02-26T22:36:11.124458Z',\n",
        "  'dependencies_met': True,\n",
-       "  'engine': '46632539-1ec7-48e9-bf3f-4608d9f3403f',\n",
+       "  'engine': '2a006992-f2fe-4a88-9356-8df7ac1ae297',\n",
        "  'status': 'ok'},\n",
        " 'content': {'status': 'ok',\n",
        "  'execution_count': 2,\n",
@@ -395,7 +398,7 @@
     {
      "data": {
       "text/plain": [
-       "'3c390298-8280dc2636a968ecb67ec5c3_66839_5'"
+       "'a2d721a7-d3a69082190b8110efa35236_96513_5'"
       ]
      },
      "execution_count": null,