From 523a7160c728270b7cebf545ff99a0d434ced4ce Mon Sep 17 00:00:00 2001 From: David Brochart Date: Wed, 23 Jul 2025 14:38:21 +0200 Subject: [PATCH] Set AkernelTask as started --- plugins/akernel_task/fps_akernel_task/akernel_task.py | 1 + plugins/akernel_task/pyproject.toml | 2 +- src/akernel/message.py | 2 +- 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/plugins/akernel_task/fps_akernel_task/akernel_task.py b/plugins/akernel_task/fps_akernel_task/akernel_task.py index fa0a978..4e88019 100644 --- a/plugins/akernel_task/fps_akernel_task/akernel_task.py +++ b/plugins/akernel_task/fps_akernel_task/akernel_task.py @@ -40,6 +40,7 @@ async def start(self, *, task_status: TaskStatus[None] = TASK_STATUS_IGNORED) -> ) self.task_group.start_soon(self.kernel.start) task_status.started() + self.started.set() await sleep_forever() async def stop(self) -> None: diff --git a/plugins/akernel_task/pyproject.toml b/plugins/akernel_task/pyproject.toml index f5fc7ee..831c4b3 100644 --- a/plugins/akernel_task/pyproject.toml +++ b/plugins/akernel_task/pyproject.toml @@ -9,7 +9,7 @@ description = "An FPS plugin for the kernel task API" keywords = ["jupyter", "server", "fastapi", "plugins"] requires-python = ">=3.9" dependencies = [ - "jupyverse-api >=0.10.0,<0.11.0", + "jupyverse-api >=0.10.1,<0.11.0", "anyio", "akernel", ] diff --git a/src/akernel/message.py b/src/akernel/message.py index bd40e96..0ca14dc 100644 --- a/src/akernel/message.py +++ b/src/akernel/message.py @@ -28,7 +28,7 @@ def utcnow() -> datetime: def feed_identities(msg_list: list[bytes]) -> tuple[list[bytes], list[bytes]]: idx = msg_list.index(DELIM) - idents = msg_list[:idx] or ["foo"] + idents = msg_list[:idx] or [b"foo"] return idents , msg_list[idx + 1 :] # noqa