From 69f7bc6555042eeac33ec36b5f59b71cacbd490e Mon Sep 17 00:00:00 2001 From: liugddx Date: Tue, 25 Aug 2026 20:06:07 +0800 Subject: [PATCH] test(runtime-host): use typed queue requests --- .../src/__tests__/execution-host-queue.test.ts | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/packages/runtime-host/src/__tests__/execution-host-queue.test.ts b/packages/runtime-host/src/__tests__/execution-host-queue.test.ts index d918317c93..40f8c22a18 100644 --- a/packages/runtime-host/src/__tests__/execution-host-queue.test.ts +++ b/packages/runtime-host/src/__tests__/execution-host-queue.test.ts @@ -245,8 +245,11 @@ test('production UDS admission commits one transcript before the root handoff', }); assert.equal(started.disposition, 'turn_started'); if (started.disposition !== 'turn_started') return; - const active = await client.queryTurn({ sessionId: fixture.sessionId, turnId: started.turnId }); - await client.stopTurn({ + const active = await client.request('turn.query', { + sessionId: fixture.sessionId, + turnId: started.turnId, + }); + await client.request('turn.stop', { sessionId: fixture.sessionId, turnId: started.turnId, runId: active.runId, @@ -268,7 +271,7 @@ test('a Host crash after queue admission recovers the durable successor once', a const firstHost = await fixture.startHost(); const first = await connectClient(fixture.root); const started = requireStartedTurn( - await first.startTurn({ + await first.request('turn.start', { sessionId: fixture.sessionId, turnId: randomUUID(), content: { text: FAKE_ASK_USER_QUESTION_PROMPT },