diff --git a/extensions/qa-lab/src/qa-channel-transport.test.ts b/extensions/qa-lab/src/qa-channel-transport.test.ts index d6f3682d96d..1b1d451a406 100644 --- a/extensions/qa-lab/src/qa-channel-transport.test.ts +++ b/extensions/qa-lab/src/qa-channel-transport.test.ts @@ -57,6 +57,7 @@ describe("qa channel transport", () => { await transport.waitReady({ gateway: { call }, timeoutMs: 2_000, + pollIntervalMs: 1, }); expect(call).toHaveBeenCalledTimes(2); diff --git a/extensions/qa-lab/src/qa-channel-transport.ts b/extensions/qa-lab/src/qa-channel-transport.ts index acad1cf55c5..8eaa06abed6 100644 --- a/extensions/qa-lab/src/qa-channel-transport.ts +++ b/extensions/qa-lab/src/qa-channel-transport.ts @@ -18,6 +18,7 @@ export const QA_CHANNEL_DEFAULT_SUITE_CONCURRENCY = 4; async function waitForQaChannelReady(params: { gateway: QaTransportGatewayClient; timeoutMs?: number; + pollIntervalMs?: number; }) { await waitForQaTransportCondition( async () => { @@ -45,7 +46,7 @@ async function waitForQaChannelReady(params: { } }, params.timeoutMs ?? 45_000, - 500, + params.pollIntervalMs ?? 500, ); } diff --git a/extensions/qa-lab/src/qa-transport.ts b/extensions/qa-lab/src/qa-transport.ts index e90dd281551..fe389fedebf 100644 --- a/extensions/qa-lab/src/qa-transport.ts +++ b/extensions/qa-lab/src/qa-transport.ts @@ -69,6 +69,7 @@ export type QaTransportCommonCapabilities = { waitForReady: (params: { gateway: QaTransportGatewayClient; timeoutMs?: number; + pollIntervalMs?: number; }) => Promise; waitForCondition: ( check: () => T | Promise | null | undefined, @@ -151,7 +152,11 @@ export type QaTransportAdapter = { state: QaTransportState; capabilities: QaTransportCommonCapabilities; createGatewayConfig: (params: { baseUrl: string }) => QaTransportGatewayConfig; - waitReady: (params: { gateway: QaTransportGatewayClient; timeoutMs?: number }) => Promise; + waitReady: (params: { + gateway: QaTransportGatewayClient; + timeoutMs?: number; + pollIntervalMs?: number; + }) => Promise; buildAgentDelivery: (params: { target: string }) => { channel: string; replyChannel: string; @@ -208,6 +213,7 @@ export abstract class QaStateBackedTransportAdapter implements QaTransportAdapte abstract waitReady: (params: { gateway: QaTransportGatewayClient; timeoutMs?: number; + pollIntervalMs?: number; }) => Promise; abstract buildAgentDelivery: (params: { target: string }) => { channel: string;