fix(enrichment): preserve unrelated table outputs

Author: TheodoreSpeaks

apps/sim/app/workspace/[workspaceId]/tables/[tableId]/components/table-grid/cells/cell-render.test.ts

@@ -64,4 +64,16 @@ describe('resolveCellRender waiting precedence', () => {
       })
     ).toEqual({ kind: 'value', text: 'person@old.example' })
   })
+
+  it('keeps ordinary workflow output visible when dependencies become unmet', () => {
+    expect(
+      resolveCellRender({
+        value: 'kept workflow result',
+        exec: execution('completed'),
+        column: COLUMN,
+        waitingOnLabels: ['Dependency'],
+        isEnrichmentOutput: false,
+      })
+    ).toEqual({ kind: 'value', text: 'kept workflow result' })
+  })
 })

apps/sim/app/workspace/[workspaceId]/tables/[tableId]/components/table-grid/cells/cell-render.tsx

@@ -84,7 +84,7 @@ export function resolveCellRender({
      * Waiting state must win over that stale value. Active reruns still keep
      * showing the previous value until their replacement lands.
      */
-    if (!inFlight && waitingOnLabels && waitingOnLabels.length > 0) {
+    if (isEnrichmentOutput && !inFlight && waitingOnLabels && waitingOnLabels.length > 0) {
       return { kind: 'waiting', labels: waitingOnLabels }
     }
 

apps/sim/lib/table/deps.test.ts

@@ -5,6 +5,7 @@ import { describe, expect, it } from 'vitest'
 import {
   areGroupDepsSatisfied,
   areOutputsFilled,
+  getGroupInvalidationColumns,
   getUnmetGroupDeps,
   isEmptyCellValue,
   isExecCancelled,
@@ -139,6 +140,28 @@ describe('optimisticallyScheduleNewlyEligibleGroups — enrichment inputs', () =
 
     expect(next).toEqual({})
   })
+
+  it('ignores legacy input mappings that point at the enrichment output', () => {
+    const legacyGroup = {
+      ...group,
+      inputMappings: [
+        ...(group.inputMappings ?? []),
+        { inputName: 'legacyEmail', columnName: 'g1_out' },
+      ],
+    }
+
+    expect(getGroupInvalidationColumns(legacyGroup)).toEqual(['name', 'domain'])
+
+    const before = makeRow(
+      { name: 'Person Name', domain: 'old.example', g1_out: 'person@old.example' },
+      { g1: completedExec('wf-g1') }
+    )
+    const next = optimisticallyScheduleNewlyEligibleGroups([legacyGroup], columns, before, {
+      g1_out: 'user-edited@example.com',
+    })
+
+    expect(next).toBeNull()
+  })
 })
 
 function completedExec(workflowId: string): RowExecutionMetadata {

apps/sim/lib/table/deps.ts

@@ -129,7 +129,10 @@ export function getUnmetGroupDeps(group: WorkflowGroup, row: TableRow): UnmetDep
 export function getGroupInvalidationColumns(group: WorkflowGroup): string[] {
   const columns = new Set(group.dependencies?.columns ?? [])
   if (group.type === 'enrichment') {
-    for (const mapping of group.inputMappings ?? []) columns.add(mapping.columnName)
+    const ownOutputColumns = new Set(group.outputs.map((output) => output.columnName))
+    for (const mapping of group.inputMappings ?? []) {
+      if (!ownOutputColumns.has(mapping.columnName)) columns.add(mapping.columnName)
+    }
   }
   return [...columns]
 }

apps/sim/lib/table/rows/executions.test.ts

@@ -205,4 +205,37 @@ describe('deriveExecClearsForDataPatch enrichment inputs', () => {
 
     expect(result.executionsPatch).toEqual({ [MANUAL_ENRICHMENT_GROUP.id]: null })
   })
+
+  it('does not re-arm when a legacy input mapping points at the enrichment output', () => {
+    const legacyGroup: WorkflowGroup = {
+      ...MANUAL_ENRICHMENT_GROUP,
+      inputMappings: [
+        ...(MANUAL_ENRICHMENT_GROUP.inputMappings ?? []),
+        { inputName: 'legacyEmail', columnName: 'email' },
+      ],
+    }
+    const schema: TableSchema = {
+      columns: [
+        { id: 'domain', name: 'Domain', type: 'string' },
+        {
+          id: 'email',
+          name: 'Email',
+          type: 'string',
+          workflowGroupId: legacyGroup.id,
+        },
+      ],
+      workflowGroups: [legacyGroup],
+    }
+    const completed = { ...EXECUTION_STATE, status: 'completed' as const }
+
+    const result = deriveExecClearsForDataPatch(
+      { email: 'user-edited@example.com' },
+      schema,
+      { [legacyGroup.id]: completed },
+      undefined,
+      { domain: 'old.example', email: 'user-edited@example.com' }
+    )
+
+    expect(result).toEqual({ executionsPatch: undefined, inFlightDownstreamGroups: [] })
+  })
 })