feat(core): expose workflow execution state

packages/cli/src/ui/commands/workflowsCommand.test.ts

@@ -8,7 +8,7 @@ import { vi, describe, it, expect, beforeEach, afterEach } from 'vitest';
 import { promises as fs } from 'node:fs';
 import os from 'node:os';
 import path from 'node:path';
-import { workflowsCommand } from './workflowsCommand.js';
+import { workflowsCommand, snapshotToTask } from './workflowsCommand.js';
 import { type CommandContext } from './types.js';
 import { createMockCommandContext } from '../../test-utils/mockCommandContext.js';
 import type { WorkflowTask, WorkflowSnapshot } from '@qwen-code/qwen-code-core';
@@ -28,10 +28,14 @@ function entry(overrides: Partial<WorkflowTask> = {}): WorkflowTask {
     isBackgrounded: true,
     abortController: new AbortController(),
     currentPhase: null,
+    currentPhaseVisitId: null,
     phases: [],
+    phaseVisits: [],
+    dispatches: [],
     agentsDispatched: 0,
     agentsCompleted: 0,
     recentLogs: [],
+    events: [],
     tokensSpent: 0,
     tokenBudgetTotal: null,
     perPhaseTokens: new Map<string | null, number>(),
@@ -670,3 +674,28 @@ describe('workflowsCommand', () => {
     });
   });
 });
+
+describe('snapshotToTask', () => {
+  it('preserves persisted lineage fields across the restart boundary', () => {
+    const task = snapshotToTask({
+      runId: 'wf_lineage',
+      sourceRunId: 'wf_origin',
+      startMode: 'retry',
+      meta: null,
+      status: 'completed',
+      script: '',
+      phases: [],
+      agentsDispatched: 0,
+      agentsCompleted: 0,
+      tokensSpent: 0,
+      tokenBudgetTotal: null,
+      perPhaseTokens: [],
+      recentLogs: [],
+      startTime: 1_700_000_000_000,
+      endTime: 1_700_000_005_000,
+    });
+
+    expect(task.sourceRunId).toBe('wf_origin');
+    expect(task.startMode).toBe('retry');
+  });
+});

packages/cli/src/ui/commands/workflowsCommand.ts

@@ -21,7 +21,7 @@ import { formatDuration, formatTokenCount } from '../utils/formatters.js';
  * `outputFile`, etc.) are filled with inert values — a snapshot is always
  * terminal, so the controls that read those fields are never reached.
  */
-function snapshotToTask(s: WorkflowSnapshot): WorkflowTask {
+export function snapshotToTask(s: WorkflowSnapshot): WorkflowTask {
   return {
     id: s.runId,
     kind: 'workflow',
@@ -30,10 +30,16 @@ function snapshotToTask(s: WorkflowSnapshot): WorkflowTask {
     meta: s.meta,
     status: s.status,
     currentPhase: null,
+    currentPhaseVisitId: null,
     phases: s.phases ?? [],
+    phaseVisits: s.phaseVisits ?? [],
+    dispatches: s.dispatches ?? [],
+    sourceRunId: s.sourceRunId,
+    startMode: s.startMode,
     agentsDispatched: s.agentsDispatched ?? 0,
     agentsCompleted: s.agentsCompleted ?? 0,
     recentLogs: s.recentLogs ?? [],
+    events: s.events ?? [],
     tokensSpent: s.tokensSpent ?? 0,
     tokenBudgetTotal: s.tokenBudgetTotal ?? null,
     perPhaseTokens: new Map(s.perPhaseTokens ?? []),
@@ -48,7 +54,7 @@ function snapshotToTask(s: WorkflowSnapshot): WorkflowTask {
     outputOffset: 0,
     notified: true,
     abortController: new AbortController(),
-  } as WorkflowTask;
+  };
 }
 
 /**

packages/core/src/agents/runtime/workflow-journal.test.ts

@@ -154,6 +154,23 @@ describe('WorkflowJournal', () => {
     expect(replay.started.get('k1')).toHaveLength(1);
   });
 
+  it('drain waits for fire-and-forget appends', async () => {
+    const j = new WorkflowJournal(path.join(dir, 'sub', 'journal.jsonl'));
+    void j.append({ type: 'started', key: 'k1', agentId: '1' });
+    void j.append({
+      type: 'result',
+      key: 'k1',
+      agentId: '1',
+      result: 'done',
+    });
+
+    await j.drain();
+
+    const replay = await j.load();
+    expect(replay.started.get('k1')).toHaveLength(1);
+    expect(replay.results.get('k1')?.result).toBe('done');
+  });
+
   it('load on a missing file returns empty maps', async () => {
     const j = new WorkflowJournal(path.join(dir, 'nope.jsonl'));
     const replay = await j.load();

packages/core/src/agents/runtime/workflow-journal.ts

@@ -179,6 +179,8 @@ export function buildReplay(entries: JournalEntry[]): JournalReplay {
  * failure must not fail the dispatch).
  */
 export class WorkflowJournal {
+  private pending = Promise.resolve();
+
   constructor(readonly path: string) {}
 
   /** Load + parse all entries into replay maps. Empty maps if no file. */
@@ -194,6 +196,13 @@ export class WorkflowJournal {
 
   /** Append one entry. Rejects only on I/O error (callers `.catch`). */
   append(entry: JournalEntry): Promise<void> {
-    return writeLine(this.path, entry);
+    const operation = this.pending.then(() => writeLine(this.path, entry));
+    this.pending = operation.catch(() => undefined);
+    return operation;
+  }
+
+  /** Wait until every append issued so far has settled. */
+  drain(): Promise<void> {
+    return this.pending;
   }
 }