romtuck/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge adfd063b37 into 09be5d45d5

Browse Source
This commit is contained in:
Ayush Ojha 2026-01-30 11:59:37 -04:00 committed by GitHub
commit 75a4e66a43
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/agents/pi-embedded-runner/compact.ts
View File

@ -58,6 +58,7 @@ import {
sanitizeToolsForGoogle,
} from "./google.js";
import { getDmHistoryLimitFromSessionKey, limitHistoryTurns } from "./history.js";
import { sanitizeToolUseResultPairing } from "../session-transcript-repair.js";
import { resolveGlobalLane, resolveSessionLane } from "./lanes.js";
import { log } from "./logger.js";
import { buildModelAliasLines, resolveModel } from "./model.js";
@ -417,10 +418,14 @@ export async function compactEmbeddedPiSessionDirect(
const validated = transcriptPolicy.validateAnthropicTurns
? validateAnthropicTurns(validatedGemini)
: validatedGemini;
const limited = limitHistoryTurns(
const truncated = limitHistoryTurns(
validated,
getDmHistoryLimitFromSessionKey(params.sessionKey, params.config),
);
// Re-repair tool_use/tool_result pairing after truncation, since
// limitHistoryTurns may slice in the middle of a paired exchange.
const limited =
truncated.length < validated.length ? sanitizeToolUseResultPairing(truncated) : truncated;
if (limited.length > 0) {
session.agent.replaceMessages(limited);
}

7
src/agents/pi-embedded-runner/run/attempt.ts
View File

@ -62,6 +62,7 @@ import {
sanitizeSessionHistory,
sanitizeToolsForGoogle,
} from "../google.js";
import { sanitizeToolUseResultPairing } from "../../session-transcript-repair.js";
import { getDmHistoryLimitFromSessionKey, limitHistoryTurns } from "../history.js";
import { log } from "../logger.js";
import { buildModelAliasLines } from "../model.js";
@ -531,10 +532,14 @@ export async function runEmbeddedAttempt(
const validated = transcriptPolicy.validateAnthropicTurns
? validateAnthropicTurns(validatedGemini)
: validatedGemini;
const limited = limitHistoryTurns(
const truncated = limitHistoryTurns(
validated,
getDmHistoryLimitFromSessionKey(params.sessionKey, params.config),
);
// Re-repair tool_use/tool_result pairing after truncation, since
// limitHistoryTurns may slice in the middle of a paired exchange.
const limited =
truncated.length < validated.length ? sanitizeToolUseResultPairing(truncated) : truncated;
cacheTrace?.recordStage("session:limited", { messages: limited });
if (limited.length > 0) {
activeSession.agent.replaceMessages(limited);