diff --git a/src/agents/pi-embedded-runner-extraparams.test.ts b/src/agents/pi-embedded-runner-extraparams.test.ts index 63eb5a64e8d..ae56156a918 100644 --- a/src/agents/pi-embedded-runner-extraparams.test.ts +++ b/src/agents/pi-embedded-runner-extraparams.test.ts @@ -274,11 +274,8 @@ function createAnthropicFastModeWrapper(baseStreamFn: StreamFn | undefined, fast return createAnthropicServiceTierWrapper(baseStreamFn, fastMode ? "auto" : "standard_only"); } +import { isAnthropicBedrockModel } from "./pi-embedded-runner/anthropic-family-cache-semantics.js"; import { createAnthropicToolPayloadCompatibilityWrapper } from "./pi-embedded-runner/anthropic-family-tool-payload-compat.js"; -import { - createBedrockNoCacheWrapper, - isAnthropicBedrockModel, -} from "./pi-embedded-runner/bedrock-stream-wrappers.js"; import { applyExtraParamsToAgent, resolveAgentTransportOverride, @@ -338,7 +335,7 @@ function installFullProviderRuntimeDepsForTest() { if (params.provider === "amazon-bedrock") { return isAnthropicBedrockModel(params.context.modelId) ? params.context.streamFn - : createBedrockNoCacheWrapper(params.context.streamFn); + : createTestBedrockNoCacheWrapper(params.context.streamFn); } if (params.provider === "google") { return createGoogleThinkingPayloadWrapper( @@ -396,6 +393,15 @@ function installFullProviderRuntimeDepsForTest() { }); } +function createTestBedrockNoCacheWrapper(baseStreamFn: StreamFn | undefined): StreamFn { + const underlying = baseStreamFn ?? (() => ({}) as ReturnType); + return (model, context, options) => + underlying(model, context, { + ...options, + cacheRetention: "none", + }); +} + function withMinimalProviderRuntimeDepsForTest(run: () => T): T { extraParamsTesting.setProviderRuntimeDepsForTest({ prepareProviderExtraParams: () => undefined,