From 86dd67a24c3c6a180a927c133287cd1c7041c839 Mon Sep 17 00:00:00 2001 From: Hare Date: Mon, 14 Sep 2026 23:31:14 +0900 Subject: [PATCH] fix: skip stopped worker protocol subscriptions --- .../src/lib/workspace/console/worker-console.ui.test.ts | 1 + .../w/[workspaceId]/workers/[workerRef]/console/+page.svelte | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/web/workspace/src/lib/workspace/console/worker-console.ui.test.ts b/web/workspace/src/lib/workspace/console/worker-console.ui.test.ts index a321d623..94f43ba6 100644 --- a/web/workspace/src/lib/workspace/console/worker-console.ui.test.ts +++ b/web/workspace/src/lib/workspace/console/worker-console.ui.test.ts @@ -380,6 +380,7 @@ Deno.test("Worker Console uses protocol observation events without transcript fe consolePage.includes("connectProtocolTransport") && consolePage.includes("handleIncomingProtocolEvent") && consolePage.includes("workspaceMultiplexer") && + consolePage.includes('targetWorker.state === "stopped"') && consolePage.includes('topic: "worker_protocol"') && !consolePage.includes("seenObservationEventIds") && consolePage.includes("createConsoleProjector") && diff --git a/web/workspace/src/routes/w/[workspaceId]/workers/[workerRef]/console/+page.svelte b/web/workspace/src/routes/w/[workspaceId]/workers/[workerRef]/console/+page.svelte index ed8d1df4..e6f205ab 100644 --- a/web/workspace/src/routes/w/[workspaceId]/workers/[workerRef]/console/+page.svelte +++ b/web/workspace/src/routes/w/[workspaceId]/workers/[workerRef]/console/+page.svelte @@ -934,7 +934,7 @@ token: number, target: ConsoleTarget, ) { - if (!targetWorker) { + if (!targetWorker || targetWorker.state === "stopped") { protocolState = "closed"; return; }