diff --git a/src/agents/pi-embedded-runner.sanitize-session-history.test.ts b/src/agents/pi-embedded-runner.sanitize-session-history.test.ts index de10ae674..97358da85 100644 --- a/src/agents/pi-embedded-runner.sanitize-session-history.test.ts +++ b/src/agents/pi-embedded-runner.sanitize-session-history.test.ts @@ -204,7 +204,7 @@ describe("sanitizeSessionHistory", () => { expect(result.map((msg) => msg.role)).toEqual(["user"]); }); - it("does not downgrade openai reasoning when the model has not changed", async () => { + it("downgrades orphaned openai reasoning even when the model has not changed", async () => { const sessionEntries = [ makeModelSnapshotEntry({ provider: "openai", @@ -222,7 +222,7 @@ describe("sanitizeSessionHistory", () => { sessionManager, }); - expect(result).toEqual(messages); + expect(result).toEqual([]); }); it("downgrades openai reasoning only when the model changes", async () => { diff --git a/src/agents/pi-embedded-runner/google.ts b/src/agents/pi-embedded-runner/google.ts index 868db5983..0293cd5d2 100644 --- a/src/agents/pi-embedded-runner/google.ts +++ b/src/agents/pi-embedded-runner/google.ts @@ -457,10 +457,9 @@ export async function sanitizeSessionHistory(params: { modelId: params.modelId, }) : false; - const sanitizedOpenAI = - isOpenAIResponsesApi && modelChanged - ? downgradeOpenAIReasoningBlocks(sanitizedToolResults) - : sanitizedToolResults; + const sanitizedOpenAI = isOpenAIResponsesApi + ? downgradeOpenAIReasoningBlocks(sanitizedToolResults) + : sanitizedToolResults; if (hasSnapshot && (!priorSnapshot || modelChanged)) { appendModelSnapshot(params.sessionManager, {