fix(tables): preserve workflow group scheduling

Author: TheodoreSpeaks

apps/sim/lib/table/application/groups.test.ts

@@ -201,6 +201,7 @@ describe('workflow and enrichment Table application commands', () => {
           id: 'generated-id',
           workflowId: 'workflow-1',
           name: 'Scoring',
+          autoRun: false,
           outputs: [{ blockId: 'block-2', path: 'score', columnName: 'score' }],
         }),
         outputColumns: [
@@ -218,6 +219,28 @@ describe('workflow and enrichment Table application commands', () => {
     expect(mocks.signal).toHaveBeenCalledWith(table.id)
   })
 
+  it('persists disabled auto-run on a newly created workflow group', async () => {
+    const result = await createWorkflowTableGroup.execute({
+      principal,
+      input: {
+        tableId: table.id,
+        workspaceId: table.workspaceId,
+        workflowId: 'workflow-1',
+        outputs: [{ blockId: 'block-2', path: 'score' }],
+        autoRun: false,
+      },
+    })
+
+    expect(result.group.autoRun).toBe(false)
+    expect(mocks.addGroup).toHaveBeenCalledWith(
+      expect.objectContaining({
+        group: expect.objectContaining({ autoRun: false }),
+        autoRun: false,
+      }),
+      'request-1'
+    )
+  })
+
   it('conceals a cross-workspace workflow before group mutation or effects', async () => {
     mocks.resolveWorkflowContext.mockRejectedValueOnce(
       Object.assign(new Error('Workflow not found'), { code: 'not_found' })
@@ -295,6 +318,32 @@ describe('workflow and enrichment Table application commands', () => {
     expect(mocks.signal).toHaveBeenCalledWith(table.id)
   })
 
+  it('allows a replacement output to reuse the removed output column name', async () => {
+    await updateWorkflowTableGroup.execute({
+      principal,
+      input: {
+        tableId: table.id,
+        workspaceId: table.workspaceId,
+        groupId: group.id,
+        outputs: [{ blockId: 'block-2', path: 'score', columnName: 'result' }],
+      },
+    })
+
+    expect(mocks.updateGroup).toHaveBeenCalledWith(
+      expect.objectContaining({
+        outputs: [{ blockId: 'block-2', path: 'score', columnName: 'result' }],
+        newOutputColumns: [
+          expect.objectContaining({
+            name: 'result',
+            type: 'number',
+            workflowGroupId: group.id,
+          }),
+        ],
+      }),
+      'request-1'
+    )
+  })
+
   it('propagates a concurrent schema conflict without audit or effects', async () => {
     const conflict = Object.assign(new Error('retry the update'), { code: 'conflict' })
     mocks.updateGroup.mockRejectedValueOnce(conflict)

apps/sim/lib/table/application/groups.ts

@@ -6,17 +6,18 @@ import type { V2AddWorkflowGroupBody } from '@/lib/api/contracts/v2/tables'
 import { OrchestrationError } from '@/lib/core/orchestration/types'
 import { runDetached } from '@/lib/core/utils/background'
 import { generateRequestId } from '@/lib/core/utils/request'
-import type {
-  ColumnDefinition,
-  DeleteWorkflowGroupData,
-  TableDefinition,
-  TableSchema,
-  UpdateWorkflowGroupData,
-  WorkflowGroup,
-  WorkflowGroupDependencies,
-  WorkflowGroupDeploymentMode,
-  WorkflowGroupInputMapping,
-  WorkflowGroupOutput,
+import {
+  type ColumnDefinition,
+  type DeleteWorkflowGroupData,
+  getColumnId,
+  type TableDefinition,
+  type TableSchema,
+  type UpdateWorkflowGroupData,
+  type WorkflowGroup,
+  type WorkflowGroupDependencies,
+  type WorkflowGroupDeploymentMode,
+  type WorkflowGroupInputMapping,
+  type WorkflowGroupOutput,
 } from '@/lib/table'
 import { defineAuthorizedTableUseCase } from '@/lib/table/application/authorized-table-use-case'
 import { resolveActiveTableContext } from '@/lib/table/application/context'
@@ -298,6 +299,7 @@ export const createWorkflowTableGroup = defineAuthorizedTableUseCase({
       ...(input.name ? { name: input.name } : {}),
       ...(input.dependencies ? { dependencies: input.dependencies } : {}),
       ...(input.deploymentMode ? { deploymentMode: input.deploymentMode } : {}),
+      autoRun: input.autoRun ?? false,
       outputs,
     }
     const actorUserId = attributedUserId(principal, context.billedAccountUserId)
@@ -678,7 +680,19 @@ export const updateWorkflowTableGroup = defineAuthorizedTableUseCase({
       const existingByKey = new Map(
         previousGroup.outputs.map((output) => [`${output.blockId}::${output.path}`, output])
       )
-      const taken = new Set(context.table.schema.columns.map((column) => column.name))
+      const requestedKeys = new Set(
+        input.outputs.map((output) => `${output.blockId}::${output.path}`)
+      )
+      const releasedColumnIds = new Set(
+        previousGroup.outputs
+          .filter((output) => !requestedKeys.has(`${output.blockId}::${output.path}`))
+          .map((output) => output.columnName)
+      )
+      const taken = new Set(
+        context.table.schema.columns
+          .filter((column) => !releasedColumnIds.has(getColumnId(column)))
+          .map((column) => column.name)
+      )
       outputs = []
       newOutputColumns = []
       for (const requested of input.outputs) {