Column ui improvements

Author: TheodoreSpeaks

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

@@ -17,6 +17,13 @@ const logger = createLogger('TableRunGroupAPI')
 
 const RunSchema = z.object({
   workspaceId: z.string().min(1, 'Workspace ID is required'),
+  /**
+   * `all` — every dep-satisfied row that isn't already running/pending.
+   * `incomplete` — same, but additionally restricted to rows whose group has
+   * never run, or whose last run ended in `failed`/`aborted`. Used by the
+   * "Run unrun & aborted rows" affordance in the group header.
+   */
+  mode: z.enum(['all', 'incomplete']).default('all'),
 })
 
 interface RouteParams {
@@ -95,6 +102,12 @@ export const POST = withRouteHandler(async (request: NextRequest, { params }: Ro
       const exec = tableRow.executions[groupId]
       if (exec?.status === 'running') return false
       if (exec?.status === 'pending' && exec?.jobId) return false
+      if (validated.mode === 'incomplete') {
+        // Include rows that have never run (no exec record) or whose last run
+        // ended in `failed`/`aborted`. Skip `completed`.
+        const status = exec?.status
+        if (status === 'completed') return false
+      }
       try {
         return areGroupDepsSatisfied(group, tableRow)
       } catch {
@@ -106,6 +119,10 @@ export const POST = withRouteHandler(async (request: NextRequest, { params }: Ro
       return NextResponse.json({ success: true, data: { triggered: 0 } })
     }
 
+    // Clear the group's output cells so the rerun starts visually fresh.
+    const clearedData = Object.fromEntries(
+      group.outputs.map((o) => [o.columnName, null])
+    ) as RowData
     const updates = eligibleRows.map((r) => {
       const pendingExec: RowExecutionMetadata = {
         status: 'pending',
@@ -116,7 +133,7 @@ export const POST = withRouteHandler(async (request: NextRequest, { params }: Ro
       }
       return {
         rowId: r.id,
-        data: {} as RowData,
+        data: clearedData,
         executionsPatch: { [groupId]: pendingExec },
       }
     })

apps/sim/app/api/table/[tableId]/rows/[rowId]/run-workflow-group/route.ts

@@ -61,11 +61,17 @@ export const POST = withRouteHandler(async (request: NextRequest, { params }: Ro
       workflowId: group.workflowId,
       error: null,
     }
+    // Clear the group's output cells so the rerun starts visually fresh —
+    // otherwise stale values from the previous run linger in the UI until the
+    // new run writes new ones (or doesn't, on error/router-skip).
+    const clearedData = Object.fromEntries(
+      group.outputs.map((o) => [o.columnName, null])
+    )
     await updateRow(
       {
         tableId,
         rowId,
-        data: {},
+        data: clearedData,
         workspaceId: validated.workspaceId,
         executionsPatch: { [validated.groupId]: pendingExec },
       },

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

@@ -92,6 +92,26 @@ function deriveOutputColumnName(
 
 const OUTPUT_VALUE_SEPARATOR = '::'
 
+type ColumnType = ColumnDefinition['type']
+
+/**
+ * Map a block-output leaf type onto a table column type. Block schemas use a
+ * superset (`array`, `object`, etc.); anything outside the column-type union
+ * falls back to `json`, the most permissive shape that still validates.
+ */
+function columnTypeForLeaf(leafType: string | undefined): ColumnType {
+  switch (leafType) {
+    case 'string':
+    case 'number':
+    case 'boolean':
+    case 'date':
+    case 'json':
+      return leafType
+    default:
+      return 'json'
+  }
+}
+
 /** Shared dashed-divider style — mirrors the workflow editor's subblock divider. */
 const DASHED_DIVIDER_STYLE = {
   backgroundImage:
@@ -509,9 +529,13 @@ export function ColumnSidebar({
    * state, sorted by execution order. Empty array if the user hasn't picked
    * anything.
    */
-  const buildOrderedPickedOutputs = (): Array<{ blockId: string; path: string }> => {
+  const buildOrderedPickedOutputs = (): Array<{
+    blockId: string
+    path: string
+    leafType?: string
+  }> => {
     const seen = new Set<string>()
-    const outputs: Array<{ blockId: string; path: string }> = []
+    const outputs: Array<{ blockId: string; path: string; leafType?: string }> = []
     for (const encoded of selectedOutputs) {
       if (seen.has(encoded)) continue
       seen.add(encoded)
@@ -532,6 +556,12 @@ export function ColumnSidebar({
       const indexInFlat = new Map(
         flat.map((f, i) => [`${f.blockId}${OUTPUT_VALUE_SEPARATOR}${f.path}`, i])
       )
+      const leafTypeByKey = new Map(
+        flat.map((f) => [`${f.blockId}${OUTPUT_VALUE_SEPARATOR}${f.path}`, f.leafType])
+      )
+      for (const o of outputs) {
+        o.leafType = leafTypeByKey.get(`${o.blockId}${OUTPUT_VALUE_SEPARATOR}${o.path}`)
+      }
       outputs.sort((a, b) => {
         const da = distances[a.blockId]
         const db = distances[b.blockId]
@@ -591,7 +621,7 @@ export function ColumnSidebar({
               fullOutputs.push({ blockId: o.blockId, path: o.path, columnName: colName })
               newOutputColumns.push({
                 name: colName,
-                type: 'string',
+                type: columnTypeForLeaf(o.leafType),
                 required: false,
                 unique: false,
                 workflowGroupId: existingGroup.id,
@@ -620,7 +650,7 @@ export function ColumnSidebar({
             taken.add(colName)
             newOutputColumns.push({
               name: colName,
-              type: 'string',
+              type: columnTypeForLeaf(o.leafType),
               required: false,
               unique: false,
               workflowGroupId: groupId,