fix(tables): resolve canonical workflow starts

Author: TheodoreSpeaks

apps/sim/background/workflow-column-execution.test.ts

@@ -57,12 +57,14 @@ const QUEUED_PAYLOAD = {
   },
 }
 
-function latestDeployment(): Parameters<typeof assertWorkflowGroupMatchesLatestDeployment>[1] {
+function latestDeployment(
+  startType = 'start_trigger'
+): Parameters<typeof assertWorkflowGroupMatchesLatestDeployment>[1] {
   return {
     blocks: {
       start: {
         id: 'start',
-        type: 'start_trigger',
+        type: startType,
         subBlocks: {
           inputFormat: { value: [{ name: 'company', type: 'string' }] },
         },
@@ -109,6 +111,20 @@ describe('latest table workflow deployment mappings', () => {
     ).not.toThrow()
   })
 
+  it('accepts a canonical split manual start block', () => {
+    expect(() =>
+      assertWorkflowGroupMatchesLatestDeployment(
+        {
+          id: 'group-1',
+          workflowId: 'workflow-1',
+          outputs: [{ blockId: 'agent', path: 'content', columnName: 'column-output' }],
+          inputMappings: [{ inputName: 'company', columnName: 'column-company' }],
+        },
+        latestDeployment('manual_trigger')
+      )
+    ).not.toThrow()
+  })
+
   it('rejects an output mapping removed by the latest active deployment', () => {
     expect(() =>
       assertWorkflowGroupMatchesLatestDeployment(

apps/sim/background/workflow-column-execution.ts

@@ -57,6 +57,7 @@ import {
 import { flattenWorkflowOutputs } from '@/lib/workflows/blocks/flatten-outputs'
 import { normalizeInputFormatValue } from '@/lib/workflows/input-format'
 import type { DeployedWorkflowData } from '@/lib/workflows/persistence/utils'
+import { TriggerUtils } from '@/lib/workflows/triggers/triggers'
 import { ResolvedSecretTraceRegistry } from '@/executor/utils/resolved-secret-trace-registry'
 
 export type { WorkflowGroupCellPayload }
@@ -85,15 +86,15 @@ export function assertWorkflowGroupMatchesLatestDeployment(
     )
   }
 
-  const startBlock = Object.values(deployment.blocks).find(
-    (block) => block.type === 'start_trigger'
-  )
-  if (!startBlock) {
+  const startCandidate = TriggerUtils.findStartBlock(deployment.blocks, 'manual')
+  if (!startCandidate) {
     throw new Error('Workflow is missing a Start trigger')
   }
 
   const validInputNames = new Set(
-    normalizeInputFormatValue(startBlock.subBlocks?.inputFormat?.value).map((input) => input.name)
+    normalizeInputFormatValue(startCandidate.block.subBlocks?.inputFormat?.value).map(
+      (input) => input.name
+    )
   )
   const invalidInput = (group.inputMappings ?? []).find(
     (mapping) => !validInputNames.has(mapping.inputName)
@@ -746,10 +747,8 @@ async function runWorkflowAndWriteTerminal(
           })
           return 'error'
         }
-        const startBlock = normalizedData
-          ? Object.values(normalizedData.blocks).find((b) => b?.type === 'start_trigger')
-          : undefined
-        if (!startBlock) {
+        const startCandidate = TriggerUtils.findStartBlock(normalizedData.blocks, 'manual')
+        if (!startCandidate) {
           await writeState({
             status: 'error',
             executionId,
@@ -1037,7 +1036,7 @@ async function runWorkflowAndWriteTerminal(
             },
             executionMode: 'sync',
             workflowTriggerType: 'table',
-            triggerBlockId: startBlock.id,
+            triggerBlockId: startCandidate.blockId,
             useDraftState: false,
             workflowStateOverride: normalizedData,
             abortSignal: attemptSignal,