feat(tables): workflow version selection (live/deployed) and not-found/no-output badges

Author: TheodoreSpeaks

apps/sim/app/api/table/[tableId]/groups/route.ts

@@ -116,6 +116,9 @@ export const PATCH = withRouteHandler(async (request: NextRequest, { params }: R
         ...(validated.inputMappings !== undefined
           ? { inputMappings: validated.inputMappings }
           : {}),
+        ...(validated.deploymentMode !== undefined
+          ? { deploymentMode: validated.deploymentMode }
+          : {}),
         ...(validated.type !== undefined ? { type: validated.type } : {}),
         ...(validated.autoRun !== undefined ? { autoRun: validated.autoRun } : {}),
       },

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

@@ -22,6 +22,7 @@ export type CellRenderKind =
   | { kind: 'error' }
   | { kind: 'waiting'; labels: string[] }
   | { kind: 'not-found' }
+  | { kind: 'no-output' }
   // Plain typed cells
   | { kind: 'boolean'; checked: boolean }
   | { kind: 'json'; text: string }
@@ -106,6 +107,9 @@ export function resolveCellRender({
     if (exec?.status === 'error') return { kind: 'error' }
     // Enrichment ran to completion but matched nothing → "Not found".
     if (isEnrichmentOutput && exec?.status === 'completed') return { kind: 'not-found' }
+    // Workflow output: the group's run completed but this block produced no
+    // value for the cell → grey "No output" (distinct from a never-run blank).
+    if (exec?.status === 'completed') return { kind: 'no-output' }
     return { kind: 'empty' }
   }
 
@@ -394,6 +398,15 @@ export function CellRender({ kind, isEditing }: CellRenderProps): React.ReactEle
         </Wrap>
       )
 
+    case 'no-output':
+      return (
+        <Wrap isEditing={isEditing}>
+          <Badge variant='gray' dot size='sm'>
+            No output
+          </Badge>
+        </Wrap>
+      )
+
     case 'empty':
       return null
 

apps/sim/app/workspace/[workspaceId]/tables/[tableId]/components/table-grid/headers/column-header-menu.tsx

@@ -1,6 +1,7 @@
 'use client'
 
 import React, { useCallback, useEffect, useRef, useState } from 'react'
+import { Badge, Tooltip } from '@/components/emcn'
 import { ChevronDown } from '@/components/emcn/icons'
 import { cn } from '@/lib/core/utils/cn'
 import type { WorkflowGroup } from '@/lib/table'
@@ -237,6 +238,21 @@ export const ColumnHeaderMenu = React.memo(function ColumnHeaderMenu({
     setMenuOpen(true)
   }
 
+  const notFoundBadge = sourceInfo?.blockMissing ? (
+    <Tooltip.Root>
+      <Tooltip.Trigger asChild>
+        <span className='ml-1.5 shrink-0'>
+          <Badge variant='gray' dot size='sm'>
+            Not found
+          </Badge>
+        </span>
+      </Tooltip.Trigger>
+      <Tooltip.Content side='top'>
+        This column's source block no longer exists in the workflow.
+      </Tooltip.Content>
+    </Tooltip.Root>
+  ) : null
+
   return (
     <th
       className={cn(
@@ -292,6 +308,7 @@ export const ColumnHeaderMenu = React.memo(function ColumnHeaderMenu({
           <span className='ml-1.5 min-w-0 overflow-clip text-ellipsis whitespace-nowrap font-medium text-[13px] text-[var(--text-primary)]'>
             {column.workflowGroupId ? column.headerLabel : column.name}
           </span>
+          {notFoundBadge}
         </div>
       ) : (
         <div className='flex h-full w-full min-w-0 items-center'>
@@ -309,6 +326,7 @@ export const ColumnHeaderMenu = React.memo(function ColumnHeaderMenu({
             <span className='ml-1.5 min-w-0 overflow-clip text-ellipsis whitespace-nowrap font-medium text-[var(--text-primary)] text-small'>
               {column.workflowGroupId ? column.headerLabel : column.name}
             </span>
+            {notFoundBadge}
           </button>
           <button
             type='button'

apps/sim/app/workspace/[workspaceId]/tables/[tableId]/components/table-grid/types.ts

@@ -9,6 +9,9 @@ export interface BlockIconInfo {
 export interface ColumnSourceInfo {
   blockIconInfo?: BlockIconInfo
   blockName?: string
+  /** Workflow loaded but the column's source block no longer exists — the
+   *  header renders a "Not found" badge. Only set for loaded states. */
+  blockMissing?: boolean
 }
 
 /**

apps/sim/app/workspace/[workspaceId]/tables/[tableId]/components/workflow-sidebar/workflow-sidebar.tsx

@@ -8,6 +8,8 @@ import { useMutation, useQueryClient } from '@tanstack/react-query'
 import { ExternalLink, RepeatIcon, SplitIcon, X } from 'lucide-react'
 import {
   Button,
+  ButtonGroup,
+  ButtonGroupItem,
   Combobox,
   type ComboboxOptionGroup,
   FieldDivider,
@@ -34,6 +36,7 @@ import type {
   ColumnDefinition,
   WorkflowGroup,
   WorkflowGroupDependencies,
+  WorkflowGroupDeploymentMode,
   WorkflowGroupInputMapping,
   WorkflowGroupOutput,
 } from '@/lib/table'
@@ -347,6 +350,11 @@ export function WorkflowSidebarBody({
   const [autoRun, setAutoRun] = useState<boolean>(() =>
     existingGroup ? existingGroup.autoRun !== false : false
   )
+  // Which workflow state per-cell runs execute against. Defaults to `'live'`
+  // (the editable draft) for both new and pre-feature groups.
+  const [deploymentMode, setDeploymentMode] = useState<WorkflowGroupDeploymentMode>(
+    () => existingGroup?.deploymentMode ?? 'live'
+  )
   // Deps default to none selected. With auto-run on, at least one is required
   // (enforced via `depsValid` below); a legacy group with empty deps will
   // surface the error on first open until the user picks at least one column.
@@ -709,6 +717,7 @@ export function WorkflowSidebarBody({
             outputs: fullOutputs,
             ...(newOutputColumns.length > 0 ? { newOutputColumns } : {}),
             inputMappings: inputMappingsList,
+            deploymentMode,
             autoRun,
           })
           toast.success(`Saved "${existingGroup.name ?? 'Workflow'}"`)
@@ -740,6 +749,7 @@ export function WorkflowSidebarBody({
           dependencies,
           outputs: groupOutputs,
           inputMappings: inputMappingsList,
+          deploymentMode,
           autoRun,
         }
         await addWorkflowGroup.mutateAsync({ group, outputColumns: newOutputColumns })
@@ -1027,12 +1037,31 @@ export function WorkflowSidebarBody({
                   <div className='h-[1.25px] flex-1' style={DASHED_DIVIDER_STYLE} />
                 </div>
                 {showAdvanced && (
-                  <InputMappingSection
-                    inputFields={startBlockInputs.existing}
-                    columnOptions={depOptions}
-                    value={inputMappings}
-                    onChange={setInputMappings}
-                  />
+                  <>
+                    {!isEnrichment && (
+                      <>
+                        <div className='flex items-center justify-between pl-0.5'>
+                          <Label>Workflow version</Label>
+                          <ButtonGroup
+                            value={deploymentMode}
+                            onValueChange={(v) =>
+                              setDeploymentMode(v === 'deployed' ? 'deployed' : 'live')
+                            }
+                          >
+                            <ButtonGroupItem value='live'>Live</ButtonGroupItem>
+                            <ButtonGroupItem value='deployed'>Deployed</ButtonGroupItem>
+                          </ButtonGroup>
+                        </div>
+                        <FieldDivider />
+                      </>
+                    )}
+                    <InputMappingSection
+                      inputFields={startBlockInputs.existing}
+                      columnOptions={depOptions}
+                      value={inputMappings}
+                      onChange={setInputMappings}
+                    />
+                  </>
                 )}
               </>
             )}

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

@@ -202,7 +202,10 @@ export function useTable({ workspaceId, tableId, queryOptions }: UseTableParams)
           ? { icon: blockConfig.icon, color: blockConfig.bgColor || '#2F55FF' }
           : undefined
         const blockName = block?.name?.trim() || undefined
-        map.set(out.columnName, { blockIconInfo, blockName })
+        // 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)
+        map.set(out.columnName, { blockIconInfo, blockName, blockMissing })
       }
     }
     return map

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

@@ -162,14 +162,25 @@ async function runWorkflowAndWriteTerminal(
   table: TableDefinition,
   group: WorkflowGroup
 ): Promise<'completed' | 'error' | 'paused' | 'blocked'> {
-  const { tableId, tableName, rowId, groupId, workflowId, workspaceId, executionId, dispatchId } =
-    payload
+  const {
+    tableId,
+    tableName,
+    rowId,
+    groupId,
+    workflowId,
+    workspaceId,
+    executionId,
+    dispatchId,
+    deploymentMode,
+  } = payload
   const requestId = `wfgrp-${executionId}`
 
   return runWithRequestContext({ requestId }, async () => {
     const { getRowById } = await import('@/lib/table/service')
     const { executeWorkflow } = await import('@/lib/workflows/executor/execute-workflow')
-    const { loadWorkflowFromNormalizedTables } = await import('@/lib/workflows/persistence/utils')
+    const { loadWorkflowFromNormalizedTables, loadDeployedWorkflowState } = await import(
+      '@/lib/workflows/persistence/utils'
+    )
     const { writeWorkflowGroupState, markWorkflowGroupPickedUp, buildOutputsByBlockId } =
       await import('@/lib/table/cell-write')
     const { stashCellContextForResume } = await import('@/lib/table/workflow-columns')
@@ -381,7 +392,26 @@ async function runWorkflowAndWriteTerminal(
         return 'error'
       }
 
-      const normalizedData = await loadWorkflowFromNormalizedTables(workflowId)
+      // `deployed` groups run the workflow's latest active deployment; `live`
+      // (default) runs the editable draft. A `deployed` group whose workflow
+      // has never been deployed fails the cell — no silent fallback to draft.
+      let normalizedData: Awaited<ReturnType<typeof loadWorkflowFromNormalizedTables>>
+      if (deploymentMode === 'deployed') {
+        try {
+          normalizedData = await loadDeployedWorkflowState(workflowId, workspaceId)
+        } catch {
+          await writeState({
+            status: 'error',
+            executionId,
+            jobId: null,
+            workflowId,
+            error: 'Workflow has no deployed version',
+          })
+          return 'error'
+        }
+      } else {
+        normalizedData = await loadWorkflowFromNormalizedTables(workflowId)
+      }
       const startBlock = normalizedData
         ? Object.values(normalizedData.blocks).find((b) => b?.type === 'start_trigger')
         : undefined
@@ -664,7 +694,10 @@ async function runWorkflowAndWriteTerminal(
             executionMode: 'sync',
             workflowTriggerType: 'table',
             triggerBlockId: startBlock.id,
-            useDraftState: true,
+            // `deployed` groups execute the latest active deployment; everything
+            // else runs the editable draft (the table default). Matches the
+            // state loaded above for start-block / output-block resolution.
+            useDraftState: deploymentMode !== 'deployed',
             abortSignal,
             onBlockStart,
             onBlockComplete,

apps/sim/hooks/queries/tables.ts

@@ -1563,6 +1563,7 @@ interface UpdateWorkflowGroupVariables {
   newOutputColumns?: UpdateWorkflowGroupBodyInput['newOutputColumns']
   mappingUpdates?: UpdateWorkflowGroupBodyInput['mappingUpdates']
   inputMappings?: UpdateWorkflowGroupBodyInput['inputMappings']
+  deploymentMode?: UpdateWorkflowGroupBodyInput['deploymentMode']
   type?: UpdateWorkflowGroupBodyInput['type']
   autoRun?: boolean
 }

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

@@ -731,6 +731,11 @@ const workflowGroupDependenciesSchema = z.object({
 
 const workflowGroupTypeSchema = z.enum(['manual', 'enrichment'])
 
+/** Which workflow state a group's per-cell runs execute against: `'live'` (the
+ *  editable draft) or `'deployed'` (the latest active deployment). Defaults to
+ *  `'live'` when omitted. */
+const workflowGroupDeploymentModeSchema = z.enum(['live', 'deployed'])
+
 /** One workflow Start-block input field ← one table column. */
 const workflowGroupInputMappingSchema = z.object({
   inputName: z.string().min(1, 'inputName cannot be empty'),
@@ -764,6 +769,8 @@ export const addWorkflowGroupBodySchema = z.object({
     outputs: z.array(workflowGroupOutputSchema).min(1),
     /** Maps the workflow's Start-block inputs to table columns. */
     inputMappings: z.array(workflowGroupInputMappingSchema).optional(),
+    /** Which workflow state per-cell runs execute against. Defaults to `'live'`. */
+    deploymentMode: workflowGroupDeploymentModeSchema.optional(),
     /** When `false`, the group never auto-fires from the scheduler — it can
      *  only be triggered manually. Defaults to `true`. Persisted on the
      *  group; distinct from the top-level `autoRun` below which is a
@@ -808,6 +815,8 @@ export const updateWorkflowGroupBodySchema = z.object({
   mappingUpdates: z.array(workflowGroupMappingUpdateSchema).optional(),
   /** Replace the group's input mappings. Omit to leave unchanged. */
   inputMappings: z.array(workflowGroupInputMappingSchema).optional(),
+  /** Change which workflow state the group runs against. Omit to leave unchanged. */
+  deploymentMode: workflowGroupDeploymentModeSchema.optional(),
   /** Update the group's provenance. Omit to leave unchanged. */
   type: workflowGroupTypeSchema.optional(),
   /** Toggle the group's persisted auto-run flag. Omit to leave unchanged. */
@@ -950,6 +959,8 @@ 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/service.ts

@@ -3465,6 +3465,7 @@ export async function updateWorkflowGroup(
         dependencies: data.dependencies ?? group.dependencies,
         outputs: newOutputs,
         ...(data.inputMappings !== undefined ? { inputMappings: data.inputMappings } : {}),
+        ...(data.deploymentMode !== undefined ? { deploymentMode: data.deploymentMode } : {}),
         ...(data.type !== undefined ? { type: data.type } : {}),
         ...(data.autoRun !== undefined ? { autoRun: data.autoRun } : {}),
       }