vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 07:50:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

docs: clarify Pi transcript ownership

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-04 06:10:33 +01:00
parent 705bde4594
commit 66267b5435
2 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -806,6 +806,8 @@ export async function runEmbeddedPiAgent(
let activeSessionId = params.sessionId;
let activeSessionFile = params.sessionFile;
let suppressNextUserMessagePersistence = params.suppressNextUserMessagePersistence ?? false;
// Pi owns JSONL persistence; this marker only lets the outer retry avoid
// replaying the same inbound channel message after overflow compaction.
let lastPersistedCurrentMessageId: string | number | undefined;
const onUserMessagePersisted: RunEmbeddedPiAgentParams["onUserMessagePersisted"] = (
message,
@@ -1648,6 +1650,9 @@ export async function runEmbeddedPiAgent(
params.currentMessageId !== undefined &&
params.currentMessageId === lastPersistedCurrentMessageId
) {
// The first attempt reached Pi far enough to persist this user turn.
// Retrying the original prompt would replay it, so resume from the
// compacted transcript and suppress the next user append.
nextAttemptPromptOverride = MID_TURN_PRECHECK_CONTINUATION_PROMPT;
suppressNextUserMessagePersistence = true;
}

4
src/gateway/server-methods/chat.directive-tags.test.ts
View File

@@ -755,6 +755,8 @@ describe("chat directive tag stripping for non-streaming final payloads", () =>
update.message !== null &&
(update.message as { role?: unknown }).role === "assistant",
);
// Agent-run delivery is a live projection; Pi message_end owns persisted
// assistant transcript entries, including stale media/text final payloads.
expect(assistantUpdates).toEqual([]);
const transcriptLines = fs
.readFileSync(mockState.transcriptPath, "utf-8")
@@ -804,6 +806,8 @@ describe("chat directive tag stripping for non-streaming final payloads", () =>
update.message !== null &&
(update.message as { role?: unknown }).role === "assistant",
);
// Normal agent-run final text must not be mirrored into JSONL by WebChat;
// Pi persists the model-visible assistant turn from message_end.
expect(assistantUpdates).toEqual([]);
const transcriptLines = fs
.readFileSync(mockState.transcriptPath, "utf-8")