fix(terminal): preserve legacy stream attribution

Author: Bill Leoutsakos

apps/sim/lib/workflows/streaming/streaming.test.ts

@@ -1043,6 +1043,69 @@ describe('createStreamingResponse agent-events-v1', () => {
     expect(events.some((event) => event.event === 'final')).toBe(true)
   })
 
+  it('suppresses final selected output when streamed content is keyed by invocation', async () => {
+    const stream = await createStreamingResponse({
+      requestId: 'request-invocation-selected-output',
+      streamConfig: {
+        selectedOutputs: ['agent-1_content'],
+      },
+      executeFn: async ({ onStream, onBlockComplete }) => {
+        await onStream({
+          stream: new ReadableStream<Uint8Array>({
+            start(controller) {
+              controller.enqueue(new TextEncoder().encode('current answer'))
+              controller.close()
+            },
+          }),
+          streamFormat: 'text',
+          blockExecutionId: 'invoke-current',
+          execution: {
+            blockId: 'agent-1',
+            success: true,
+            output: { content: 'current answer' },
+            logs: [],
+            metadata: {},
+          },
+        } as any)
+        await onBlockComplete('agent-1', { content: 'current answer' }, 'invoke-current')
+
+        return {
+          success: true,
+          output: { content: 'current answer' },
+          logs: [
+            {
+              blockId: 'agent-1',
+              blockExecutionId: 'invoke-stale',
+              output: { content: 'stale answer' },
+              startedAt: new Date().toISOString(),
+              endedAt: new Date().toISOString(),
+              durationMs: 1,
+              success: true,
+            },
+            {
+              blockId: 'agent-1',
+              blockExecutionId: 'invoke-current',
+              output: { content: '' },
+              startedAt: new Date().toISOString(),
+              endedAt: new Date().toISOString(),
+              durationMs: 1,
+              success: true,
+            },
+          ],
+        } as any
+      },
+    })
+
+    const events = await collectSSEEvents(stream)
+    expect(events.filter((event) => event.chunk !== undefined)).toEqual([
+      { blockId: 'agent-1', chunk: 'current answer' },
+    ])
+    expect(events.find((event) => event.event === 'final')).toEqual({
+      event: 'final',
+      data: { success: true, output: {} },
+    })
+  })
+
   it('stays fully text-only when both policies are off', async () => {
     const stream = await createStreamingResponse({
       requestId: 'request-1',

apps/sim/lib/workflows/streaming/streaming.ts

@@ -387,8 +387,15 @@ async function buildMinimalResult(
   let selectedOutputBytes = assertSelectedOutputBytes(minimalResult.output)
   for (const descriptor of getSelectedOutputDescriptors(selectedOutputs)) {
     const { blockId, path } = descriptor
+    const blockLogs = result.logs.filter((log: BlockLog) => log.blockId === blockId)
 
-    if (streamedContent.has(blockId)) {
+    if (
+      streamedContent.has(blockId) ||
+      blockLogs.some(
+        (log: BlockLog) =>
+          log.blockExecutionId !== undefined && streamedContent.has(log.blockExecutionId)
+      )
+    ) {
       continue
     }
 
@@ -410,7 +417,7 @@ async function buildMinimalResult(
       continue
     }
 
-    const blockLog = result.logs.find((log: BlockLog) => log.blockId === blockId)
+    const blockLog = blockLogs[0]
     if (!blockLog?.output) {
       continue
     }

apps/sim/stores/terminal/console/store.test.ts

@@ -285,6 +285,38 @@ describe('terminal console store', () => {
         expect.objectContaining({ blockId: 'function-1', candidateCount: 2 })
       )
     })
+
+    it('enriches an exactly matched legacy child workflow entry with its instance id', () => {
+      useTerminalConsoleStore.getState().addConsole({
+        workflowId: 'wf-1',
+        blockId: 'workflow-1',
+        blockName: 'Workflow',
+        blockType: 'workflow',
+        executionId: 'exec-1',
+        executionOrder: 3,
+        iterationCurrent: 1,
+        iterationType: 'loop',
+        iterationContainerId: 'loop-1',
+        isRunning: true,
+      })
+
+      useTerminalConsoleStore.getState().updateConsole(
+        'workflow-1',
+        {
+          childWorkflowInstanceId: 'child-inst-1',
+          executionOrder: 3,
+          iterationCurrent: 1,
+          iterationType: 'loop',
+          iterationContainerId: 'loop-1',
+        },
+        'exec-1'
+      )
+
+      expect(useTerminalConsoleStore.getState().getWorkflowEntries('wf-1')[0]).toMatchObject({
+        childWorkflowInstanceId: 'child-inst-1',
+        isRunning: true,
+      })
+    })
   })
 
   describe('cancelRunningEntries', () => {

apps/sim/stores/terminal/console/store.ts

@@ -167,6 +167,7 @@ const matchesEntryForUpdate = (
 
   if (
     update.childWorkflowInstanceId !== undefined &&
+    entry.childWorkflowInstanceId !== undefined &&
     entry.childWorkflowInstanceId !== update.childWorkflowInstanceId
   ) {
     return false