From a4189385243ca544e283ce4e9c4187a3b51e9a32 Mon Sep 17 00:00:00 2001
From: Dotta <bippadotta@protonmail.com>
Date: Thu, 3 Sep 2026 05:11:55 -0500
Subject: [PATCH] test(runner): await active suspension state

---
 .../src/drivers/acpx/runtime-host.test.ts        | 16 +++++++++-------
 .../src/live/runnerd-codex-transport.test.ts     |  6 ++++++
 2 files changed, 15 insertions(+), 7 deletions(-)

diff --git a/packages/paperclip-runner/src/drivers/acpx/runtime-host.test.ts b/packages/paperclip-runner/src/drivers/acpx/runtime-host.test.ts
index 9bc3f1a4ac..f1b3199ec8 100644
--- a/packages/paperclip-runner/src/drivers/acpx/runtime-host.test.ts
+++ b/packages/paperclip-runner/src/drivers/acpx/runtime-host.test.ts
@@ -211,13 +211,15 @@ describe("ACPX runtime host", () => {
     expect(createRuntime).not.toHaveBeenCalled();
     expect(fixture.commandClose).toHaveBeenCalledOnce();
     const authPath = join(credentialHome, "auth.json");
-    const contender = await vi.waitFor(() =>
-      stageManagedCodexCredential({
-        agentHomeDirectory: credentialHome,
-        environment: {
-          PAPERCLIP_ACPX_CODEX_AUTH_JSON_SECRET: '{"owner":"contender"}',
-        },
-      }),
+    const contender = await vi.waitFor(
+      () =>
+        stageManagedCodexCredential({
+          agentHomeDirectory: credentialHome,
+          environment: {
+            PAPERCLIP_ACPX_CODEX_AUTH_JSON_SECRET: '{"owner":"contender"}',
+          },
+        }),
+      { timeout: 5_000 },
     );
     await contender.close();
     await expect(readFile(authPath)).rejects.toMatchObject({ code: "ENOENT" });
diff --git a/packages/paperclip-runner/src/live/runnerd-codex-transport.test.ts b/packages/paperclip-runner/src/live/runnerd-codex-transport.test.ts
index 024e18b2d2..a6f5519819 100644
--- a/packages/paperclip-runner/src/live/runnerd-codex-transport.test.ts
+++ b/packages/paperclip-runner/src/live/runnerd-codex-transport.test.ts
@@ -2103,6 +2103,12 @@ it("persists an active provider as settled before bounded suspension", async ()
     await bundle.transport.request("turn/start", {
       input: [{ type: "text", text: "Wait for another instruction." }],
     });
+    const notifications = bundle.transport
+      .notifications()
+      [Symbol.asyncIterator]();
+    await expect(notifications.next()).resolves.toMatchObject({
+      value: { method: "turn/started" },
+    });
     await bundle.transport.close();
 
     const providerState = JSON.parse(