From 56648f613d11c7ecfa17a35ee76273b44b539480 Mon Sep 17 00:00:00 2001 From: Michael Johnston Date: Sun, 11 Oct 2026 04:01:13 -0700 Subject: [PATCH] test(server): finish workflow reads before changing transcripts Use the existing frame acknowledgement before changing transcript fixtures, retaining retry timestamp assertions. Carry-Group: upstream-bugfixes Carry-Upstream: https://redirect.github.com/pingdotgg/t3code/pull/18192 (8a5ec7b1cc7ddb9206a4852b95e10e1430692dcb) Carry-Observation: Await prior workflow snapshot reads before changing transcript fixtures; production behavior and assertions are unchanged. --- .../src/orchestration-v2/Adapters/ClaudeAdapterV2.test.ts | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/apps/server/src/orchestration-v2/Adapters/ClaudeAdapterV2.test.ts b/apps/server/src/orchestration-v2/Adapters/ClaudeAdapterV2.test.ts index af3055a81d1e..bc817318180e 100644 --- a/apps/server/src/orchestration-v2/Adapters/ClaudeAdapterV2.test.ts +++ b/apps/server/src/orchestration-v2/Adapters/ClaudeAdapterV2.test.ts @@ -13455,8 +13455,7 @@ describe("ClaudeAdapterV2 background wake turns", () => { NodePath.join(harness.transcriptDir, "agent-a1.jsonl"), '{"type":"assistant","message":{"role":"assistant","id":"msg_a1","content":[{"type":"text","text":"A1 continued"}]}}\n', ); - yield* Queue.offer( - harness.sdkMessages, + yield* harness.offerAndWait( workflowSnapshot({ uuid: "00000000-0000-4000-8000-000000001015", state: "done" }), ); yield* awaitUntil( @@ -13479,8 +13478,7 @@ describe("ClaudeAdapterV2 background wake turns", () => { NodePath.join(harness.transcriptDir, "agent-a2.jsonl"), '{"type":"assistant","message":{"role":"assistant","id":"msg_a2","content":[{"type":"text","text":"A2 from the transcript"}]}}\n', ); - yield* Queue.offer( - harness.sdkMessages, + yield* harness.offerAndWait( workflowSnapshot({ uuid: "00000000-0000-4000-8000-000000001016", state: "done" }), ); yield* awaitUntil(