fix(tables): per-group version in cascade, accurate deploy error, skip not-found for deployed groups

Author: TheodoreSpeaks

apps/sim/app/workspace/[workspaceId]/tables/[tableId]/hooks/use-table.ts

@@ -195,6 +195,10 @@ export function useTable({ workspaceId, tableId, queryOptions }: UseTableParams)
       if (group.type === 'enrichment') continue
       const state = workflowStates.get(group.workflowId)
       const blocks = (state as { blocks?: Record<string, FlattenOutputsBlockInput> } | null)?.blocks
+      // `useWorkflowStates` only fetches the live draft, so we can only judge
+      // "block missing" for live-mode groups. A deployed-mode group runs a
+      // different graph we don't load client-side — don't risk a false badge.
+      const isLiveMode = group.deploymentMode !== 'deployed'
       for (const out of group.outputs) {
         const block = blocks?.[out.blockId]
         const blockConfig = block?.type ? getBlock(block.type) : undefined
@@ -204,7 +208,7 @@ export function useTable({ workspaceId, tableId, queryOptions }: UseTableParams)
         const blockName = block?.name?.trim() || undefined
         // Flag a missing source block only once the workflow state has loaded
         // (truthy `blocks`), so a still-loading workflow never flashes the badge.
-        const blockMissing = Boolean(blocks && out.blockId && !block)
+        const blockMissing = Boolean(isLiveMode && blocks && out.blockId && !block)
         map.set(out.columnName, { blockIconInfo, blockName, blockMissing })
       }
     }

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

@@ -162,17 +162,12 @@ async function runWorkflowAndWriteTerminal(
   table: TableDefinition,
   group: WorkflowGroup
 ): Promise<'completed' | 'error' | 'paused' | 'blocked'> {
-  const {
-    tableId,
-    tableName,
-    rowId,
-    groupId,
-    workflowId,
-    workspaceId,
-    executionId,
-    dispatchId,
-    deploymentMode,
-  } = payload
+  const { tableId, tableName, rowId, groupId, workflowId, workspaceId, executionId, dispatchId } =
+    payload
+  // Read from the live `group`, not the payload: in a cascade the payload is the
+  // first group's snapshot, so a downstream group with a different version must
+  // use its own setting (same reason `workflowId` is re-derived per iteration).
+  const deploymentMode = group.deploymentMode
   const requestId = `wfgrp-${executionId}`
 
   return runWithRequestContext({ requestId }, async () => {
@@ -399,13 +394,15 @@ async function runWorkflowAndWriteTerminal(
       if (deploymentMode === 'deployed') {
         try {
           normalizedData = await loadDeployedWorkflowState(workflowId, workspaceId)
-        } catch {
+        } catch (err) {
+          // Surface the real reason (missing deployment vs. transient DB/migration
+          // failure) rather than always claiming the workflow isn't deployed.
           await writeState({
             status: 'error',
             executionId,
             jobId: null,
             workflowId,
-            error: 'Workflow has no deployed version',
+            error: toError(err).message,
           })
           return 'error'
         }

apps/sim/lib/api/contracts/tables.ts

@@ -959,8 +959,6 @@ export const runColumnContract = defineRouteContract({
 
 export type AddWorkflowGroupBodyInput = z.input<typeof addWorkflowGroupBodySchema>
 export type UpdateWorkflowGroupBodyInput = z.input<typeof updateWorkflowGroupBodySchema>
-/** Which workflow state a group runs against — shared by UI / hooks. */
-export type WorkflowGroupDeploymentMode = z.input<typeof workflowGroupDeploymentModeSchema>
 export type DeleteWorkflowGroupBodyInput = z.input<typeof deleteWorkflowGroupBodySchema>
 export type CancelTableRunsBodyInput = z.input<typeof cancelTableRunsBodySchema>
 export type RunColumnBodyInput = z.input<typeof runColumnBodySchema>

apps/sim/lib/table/workflow-columns.ts

@@ -22,7 +22,6 @@ import type {
   TableRow,
   TableSchema,
   WorkflowGroup,
-  WorkflowGroupDeploymentMode,
 } from '@/lib/table/types'
 
 const logger = createLogger('WorkflowGroupScheduler')
@@ -207,7 +206,6 @@ export function buildPendingRuns(
         groupId: group.id,
         workflowId: group.workflowId,
         ...(group.enrichmentId ? { enrichmentId: group.enrichmentId } : {}),
-        ...(group.deploymentMode ? { deploymentMode: group.deploymentMode } : {}),
         workspaceId: table.workspaceId,
         executionId: generateId(),
       })
@@ -331,10 +329,6 @@ export interface WorkflowGroupCellPayload {
   enrichmentId?: string
   workspaceId: string
   executionId: string
-  /** Which workflow state to execute: `'live'` (editable draft, default) or
-   *  `'deployed'` (latest active deployment). Copied from the group at enqueue
-   *  so a mid-run config change doesn't repoint in-flight cells. */
-  deploymentMode?: WorkflowGroupDeploymentMode
   /** Owning dispatch, set by `dispatcherStep`. Lets the cell halt its dispatch
    *  on a hard stop (e.g. usage limit). Absent for cascade/auto-fire payloads
    *  that aren't driven by a dispatch. */