smashimo/oh-my-pi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(task): kept async job status while forwarding subagent progress

Browse Source 
forwardSyncProgress copied the subagent's initial pending snapshot over the job-owned running status via a wholesale Object.assign, reverting mixed-split job rows to pending. Forward only the live metric fields (resolved model, reasoning, counters, recent activity) and leave status/identity to the job body.

Fixes #5060
This commit is contained in:
roboomp
2026-07-15 00:52:36 +00:00
parent 8621b0459d
commit d3d21e3b4a
1 changed files with 16 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/coding-agent/src/task/index.ts
+16 -1
View File
@@ -983,9 +983,24 @@ export class TaskTool implements AgentTool<TaskToolSchemaInstance, TaskToolDetai
const forwardSyncProgress: AgentToolUpdateCallback<TaskToolDetails> = async update => {
const nextProgress = update.details?.progress?.[0];
if (nextProgress) {
Object.assign(progress, nextProgress);
// The job body owns status and identity (id/index/agent);
// copy only the live metrics the subagent streams so the
// polling row reflects the resolved model, reasoning level,
// and running counters without reverting the "running"
// status back to the subagent's initial "pending" snapshot.
progress.resolvedModel = nextProgress.resolvedModel;
progress.tokens = nextProgress.tokens;
progress.requests = nextProgress.requests;
progress.contextTokens = nextProgress.contextTokens;
progress.contextWindow = nextProgress.contextWindow;
progress.cost = nextProgress.cost;
progress.toolCount = nextProgress.toolCount;
progress.currentTool = nextProgress.currentTool;
progress.lastIntent = nextProgress.lastIntent;
progress.recentTools = nextProgress.recentTools.slice();
progress.recentOutput = nextProgress.recentOutput.slice();
progress.retryState = nextProgress.retryState;
progress.retryFailure = nextProgress.retryFailure;
}
const updateText =
update.content.find(part => part.type === "text")?.text ?? `Running background task ${agentId}...`;