fix: preserve queued/running status and avoid false failure labels

src/cli.ts

@@ -277,7 +277,8 @@ async function run(
   }
 
   if (outcome.status !== "completed" || !outcome.asset) {
-    progress.stop(options.json ? undefined : "Failed");
+    progress.stop(options.json ? undefined : ["failed", "cancelled"].includes(outcome.status)
+      ? "Failed" : "Output not confirmed; check the saved execution.");
     if (outcome.status === "failed" && outcome.execution_id) {
       const terminal = terminalExecutionError(await api.getExecution(outcome.execution_id));
       if (terminal) throw terminal;

src/render.ts

@@ -96,6 +96,14 @@ export async function consume(
       if (event.event === "started") {
         outcome.execution_id = String(event.data.execution_id);
         outcome.conversation_id = String(event.data.conversation_id);
+        outcome.status = "queued";
+      } else if (event.event === "job") {
+        // A dropped/idle stream is not an unknown or failed execution. Keep
+        // the most recent server-reported state alongside its recovery ID.
+        const status = String(event.data.status);
+        if (["queued", "running", "completed", "failed", "cancelled"].includes(status)) {
+          outcome.status = status;
+        }
       } else if (event.event === "asset") {
         outcome.asset = {
           asset_id: String(event.data.asset_id),

test/render.test.mjs

@@ -0,0 +1,37 @@
+import assert from "node:assert/strict";
+import { test } from "node:test";
+import { consume, Progress } from "../dist/render.js";
+
+const started = { event: "started", id: "1", data: { execution_id: "execution-1", conversation_id: "conversation-1" } };
+
+test("stream interruption preserves running status and execution identity", async () => {
+  const failure = new Error("stream idle");
+  async function* events() {
+    yield started;
+    yield { event: "job", id: "2", data: { status: "running" } };
+    throw failure;
+  }
+  await assert.rejects(consume(events(), new Progress(false)), (error) => {
+    assert.equal(error, failure);
+    assert.equal(error.partialOutcome.status, "running");
+    assert.equal(error.partialOutcome.execution_id, "execution-1");
+    assert.equal(error.partialOutcome.last_event_id, "2");
+    return true;
+  });
+});
+
+test("a started execution without a terminal event stays queued, not failed", async () => {
+  async function* events() { yield started; }
+  const outcome = await consume(events(), new Progress(false));
+  assert.equal(outcome.status, "queued");
+  assert.equal(outcome.asset, null);
+});
+
+test("terminal status remains authoritative after progress", async () => {
+  async function* events() {
+    yield started;
+    yield { event: "job", id: "2", data: { status: "running" } };
+    yield { event: "done", id: "3", data: { status: "failed" } };
+  }
+  assert.equal((await consume(events(), new Progress(false))).status, "failed");
+});