authorgravatar for anshsinghapa@gmail.comANSH SINGH <anshsinghapa@gmail.com> 2026-10-12 07:11:46+05:30
committergravatar for noreply@github.comGitHub <noreply@github.com> 2026-10-12 01:41:46+00:00
log4a90c1cf5db5f25893827643fb32d3304dddcdd9
tree94115cbf4a8d1157c5c80cebf16648f12b054da8
parentb8d03ba2dd2a511899a5187c0fbe477ef2b40bbe
signature Signed by PGP key B5690EEEBB952194

fix(web): keep queued threads subscribed (#15293)

Co-authored-by: maria <maria@kuuro.net>

2 files changed, 8 insertions(+), 2 deletions(-)

apps/web/src/state/threads.test.ts+7-1
......@@ -19,7 +19,7 @@ import { createRunningThreadKeepAliveAtom } from "./threads";
1919const LOCAL = EnvironmentId.make("local");
2020const REMOTE = EnvironmentId.make("remote");
2121
22type Status = "running" | "starting" | "idle";
22type Status = "running" | "starting" | "preparing" | "queued" | "waiting" | "idle";
2323function shell(id: string, status: Status | null) {
2424 return { id: ThreadId.make(id), status: status ?? "idle" } satisfies Pick<
2525 OrchestrationV2ThreadShell,
......@@ -159,6 +159,12 @@ describe("createRunningThreadKeepAliveAtom", () => {
159159 expect(h.openStreams()).toEqual([]);
160160 });
161161
162 it("keeps queued threads open", () => {
163 const h = makeHarness();
164 h.registry.set(h.threads(LOCAL), [shell("a", "queued")]);
165 expect(h.openStreams()).toEqual(["local:a"]);
166 });
167
162168 it("follows environments that connect and go away", () => {
163169 const h = makeHarness();
164170 h.registry.set(h.environmentIds, [LOCAL]);
apps/web/src/state/threads.ts+1-1
......@@ -51,7 +51,7 @@ export function useEnvironmentThread(
5151}
5252
5353const isRunning = (status: string) =>
54 status === "preparing" || status === "starting" || status === "running";
54 status === "preparing" || status === "queued" || status === "starting" || status === "running";
5555
5656type KeptThreads = ReadonlyMap<EnvironmentId, ReadonlySet<ThreadId>>;
5757