diff --git a/src/main/native-chat/agent-session-wire/host/testing/structured-agent-session-codex-stop-note-end.test.ts b/src/main/native-chat/agent-session-wire/host/testing/structured-agent-session-codex-stop-note-end.test.ts index b132bb64b01..3b523907c48 100644 --- a/src/main/native-chat/agent-session-wire/host/testing/structured-agent-session-codex-stop-note-end.test.ts +++ b/src/main/native-chat/agent-session-wire/host/testing/structured-agent-session-codex-stop-note-end.test.ts @@ -251,13 +251,17 @@ it('settles a settings timeout before review as refused and admits the next norm return { turn: { id: 'normal-after-settings' } } } expect(await host.send(CALLER, send)).toMatchObject({ ok: true }) - const after = await host.journalSnapshot(SESSION) - expect( - after.submissions.find( - ({ clientMessageId }) => clientMessageId === send.envelope.clientOperationId + await vi.waitFor(async () => { + const after = await host.journalSnapshot(SESSION) + expect( + after.submissions.find( + ({ clientMessageId }) => clientMessageId === send.envelope.clientOperationId + ) + ).toMatchObject({ dispatchState: 'accepted' }) + expect( + after.items.map(({ body }) => readAgentJournalTurn(body)).filter(Boolean) + ).toContainEqual( + expect.objectContaining({ providerTurnId: 'normal-after-settings', state: 'running' }) ) - ).toMatchObject({ dispatchState: 'accepted' }) - expect(after.items.map(({ body }) => readAgentJournalTurn(body)).filter(Boolean)).toContainEqual( - expect.objectContaining({ providerTurnId: 'normal-after-settings', state: 'running' }) - ) + }) })