fix(tui): preserve workflow lifecycle progress

Author: elkaix

apps/pythinker-code/src/tui/components/messages/dynamic-workflow-mission-control.ts

@@ -261,13 +261,21 @@ export class DynamicWorkflowMissionControlComponent implements Component {
     this.recordActivity(member.index, 'Started');
   }
 
+  private markStartedFromActivity(member: DynamicWorkflowMember): void {
+    if (member.phase !== 'pending' && member.phase !== 'queued') return;
+    member.phase = 'running';
+    member.startedAtMs ??= Date.now();
+    delete member.statusDetail;
+    this.recordActivity(member.index, 'Started');
+  }
+
   recordToolCall(input: {
     readonly agentId: string;
     readonly name?: string;
   }): void {
     const member = this.findMemberByAgentId(input.agentId);
     if (member === undefined || isTerminalPhase(member.phase)) return;
-    this.markStarted(input.agentId);
+    this.markStartedFromActivity(member);
     const latest = input.name === undefined ? 'Using a tool' : `Using ${input.name}`;
     this.setLatest(member, latest, true);
     // Streamed text that follows starts a new line, never continues this label.
@@ -277,7 +285,7 @@ export class DynamicWorkflowMissionControlComponent implements Component {
   appendModelDelta(input: { readonly agentId: string; readonly delta: string }): void {
     const member = this.findMemberByAgentId(input.agentId);
     if (member === undefined || isTerminalPhase(member.phase) || input.delta.length === 0) return;
-    this.markStarted(input.agentId);
+    this.markStartedFromActivity(member);
     const combined = `${member.carry}${input.delta}`;
     // Only the text after the last newline is still being written. A delta that
     // ends exactly at a newline leaves nothing pending, so carrying the closed
@@ -926,7 +934,8 @@ function parseDynamicWorkflowResultStatuses(output: string): DynamicWorkflowResu
       outcome === 'completed' ||
       outcome === 'failed' ||
       outcome === 'aborted' ||
-      outcome === 'cancelled'
+      outcome === 'cancelled' ||
+      outcome === 'schema_error'
     ) {
       // Omitted `index` falls back to the lowest free slot so unordered tags
       // still render in ascending row order.
@@ -948,7 +957,11 @@ function parseDynamicWorkflowResultStatuses(output: string): DynamicWorkflowResu
           index,
           agentId: xmlAttribute(attrs, 'agent_id'),
           item: xmlAttribute(attrs, 'item'),
-          status: outcome === 'aborted' || outcome === 'cancelled' ? 'cancelled' : outcome,
+          status: outcome === 'aborted' || outcome === 'cancelled'
+            ? 'cancelled'
+            : outcome === 'schema_error'
+              ? 'failed'
+              : outcome,
           detail: normalizeText(decodeXmlEntities(body)),
         });
       }

apps/pythinker-code/test/tui/components/messages/dynamic-workflow-mission-control.test.ts

@@ -124,6 +124,28 @@ describe('DynamicWorkflowMissionControlComponent', () => {
     }
   });
 
+  it('maps schema errors to failed rows without shifting later results', () => {
+    const result = [
+      '<dynamic_workflow_result>',
+      '<subagent outcome="schema_error">Invalid structured output</subagent>',
+      '<subagent outcome="completed">Valid result</subagent>',
+      '</dynamic_workflow_result>',
+    ].join('\n');
+    const component = createComponent();
+    component.updateArgs({ items: ['Schema work', 'Normal work'] });
+    component.markInputComplete();
+
+    expect(dynamicWorkflowResultSummaryFromOutput(result)).toEqual({
+      completed: 1,
+      failed: 1,
+      aborted: 0,
+      parsed: true,
+    });
+    expect(component.applyResult(result)).toBe(true);
+    expect(memberLine(renderText(component, 120), 1)).toMatch(/×\s+FAIL\s+Schema work/u);
+    expect(memberLine(renderText(component, 120), 2)).toMatch(/●\s+DONE\s+Normal work/u);
+  });
+
   it('ignores blank items so no phantom row waits forever', () => {
     const component = createComponent();
     // The engine drops the blank before launching anything, so counting it here
@@ -479,6 +501,23 @@ describe('DynamicWorkflowMissionControlComponent', () => {
     expect(output).not.toMatch(/\d+%/u);
   });
 
+  it('keeps late activity suspended until a lifecycle start resumes it', () => {
+    const component = createComponent();
+    component.updateArgs({ items: ['Rate-limited work'] });
+    component.markInputComplete();
+    component.registerSubagent({ agentId: 'agent-1' });
+    component.markStarted('agent-1');
+    component.markSuspended({ agentId: 'agent-1', reason: 'Rate limited' });
+
+    component.appendModelDelta({ agentId: 'agent-1', delta: 'Late output' });
+    component.recordToolCall({ agentId: 'agent-1', name: 'Read' });
+    expect(memberLine(renderText(component, 100), 1)).toMatch(/◑\s+HOLD/u);
+    expect(renderText(component, 100)).toContain('Rate limited');
+
+    component.markStarted('agent-1');
+    expect(memberLine(renderText(component, 100), 1)).toMatch(/[○◔◑◕]\s+RUN/u);
+  });
+
   it('prefers a suspension detail over stale model progress in the member row', () => {
     const component = createComponent({ availableRows: () => 5 });
     component.updateArgs({ items: ['Throttle-sensitive work'] });