From 9b9792ead5d5b1bad9b713336c90de6af81b1d39 Mon Sep 17 00:00:00 2001 From: Michael Johnston Date: Sun, 11 Oct 2026 18:07:20 -0700 Subject: [PATCH] test(server): finish workflow reads before changing transcripts (#18192) --- .../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 4bf007065a739b6b076b62278fba6e135c3576b9..cc4896c9afb04bc27fb36bac6f5520a29822d5f3 100644 --- a/apps/server/src/orchestration-v2/Adapters/ClaudeAdapterV2.test.ts +++ b/apps/server/src/orchestration-v2/Adapters/ClaudeAdapterV2.test.ts @@ -13241,8 +13241,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( @@ -13265,8 +13264,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( -- 2.54.0