puter/paseo
1
0
Fork 0
mirror of https://github.com/getpaseo/paseo.git synced 2026-10-24 10:12:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(claude): release a settled subagent call when the child finishes

Browse Source
This commit is contained in:
paseo-bot[bot]
2026-10-06 18:21:02 +02:00
parent 08f376f501
commit 3a51db2db2
1 changed files with 16 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/server/src/server/agent/providers/claude/agent.ts
+16 -4
View File
@@ -2095,8 +2095,9 @@ class ClaudeAgentSession implements AgentSession {
readWorkflowResult: readClaudeWorkflowResultFile,
});
/**
* Subagent tool calls Claude has already answered, with the input they were launched with. A
* background child is answered at launch and streams its frames afterwards.
* Subagent tool calls Claude has already answered while the child still runs, with the input
* they were launched with. A background child is answered at launch and streams its frames
* afterwards.
*/
private readonly settledSubagentToolCalls = new Map<
string,
@@ -4145,6 +4146,7 @@ class ClaudeAgentSession implements AgentSession {
for (const event of foldSubagentObservations(subagentObservations)) {
events.push({ type: "provider_subagent", provider: "claude", event });
}
this.releaseFinishedSubagentToolCalls(subagentObservations);
for (const observation of subagentObservations) {
if (observation.kind !== "declared") continue;
if (!this.taskProtocolSource.needsSyntheticParentToolCard(observation.id)) continue;
@@ -5355,8 +5357,18 @@ class ClaudeAgentSession implements AgentSession {
item: Extract<AgentTimelineItem, { type: "tool_call" }> | null,
entry: ToolUseCacheEntry | undefined,
): void {
if (!item || !this.taskProtocolSource.resolveSubagentId(item.callId)) return;
this.settledSubagentToolCalls.set(item.callId, { item, input: entry?.input ?? null });
const subagentId = item ? this.taskProtocolSource.resolveSubagentId(item.callId) : undefined;
if (!item || !subagentId) return;
this.settledSubagentToolCalls.set(subagentId, { item, input: entry?.input ?? null });
}
/** A finished child streams no more frames, so its settled call has nothing left to update. */
private releaseFinishedSubagentToolCalls(observations: SubagentObservation[]): void {
for (const observation of observations) {
if (observation.kind === "status" && observation.status !== "running") {
this.settledSubagentToolCalls.delete(observation.id);
}
}
}
private buildToolOutput(