route and connection validation, trigger defaults on add, table folder restore, dispatch listing, group column attach, import block summary; logs query and deps engines; run-tool errors and payload compaction; stale tests aligned

Editing: router routes validated as {id?, title, value} with unknown keys named; malformed connections reported instead of dropped; sub-block value() defaults evaluated on add so a webhook gets its token. Tables: folder restore no longer 500s (lock inside the row transaction), completed dispatches are listed, groups attach to existing output columns. Workflows: import answers with its blocks. Mothership engines: logs query resolves bare paths under output, marks missing paths, drops non-executed runs under --where; deps lists graph predecessors and child return shapes; run-from-block validation errors reach the agent; run payloads compact input.code. CLI generated types regenerated.

Author: Sg312

apps/docs/openapi-v2-tables.json

@@ -2126,7 +2126,7 @@
       "post": {
         "operationId": "addTableWorkflowGroup",
         "summary": "Add Workflow Group",
-        "description": "Bind a workflow or enrichment to the table and create the columns populated by its outputs.",
+        "description": "Bind a workflow or enrichment to the table and create the columns populated by its outputs. An output whose column the table already has attaches that column to the group instead of creating it, so `outputColumns` may be omitted when every output lands in an existing column.",
         "tags": ["Tables"],
         "parameters": [
           {
@@ -2459,8 +2459,8 @@
       },
       "get": {
         "operationId": "listTableDispatches",
-        "summary": "List Active Run Dispatches",
-        "description": "List the run dispatches still in flight on one table. Bounded by the dispatcher rather than by a page size, so this list is unpaginated and `nextCursor` is always null. A settled dispatch is read by identifier.",
+        "summary": "List Run Dispatches",
+        "description": "List the run dispatches on one table, most recent first — settled dispatches (`complete`, `canceled`) alongside the ones still in flight, so a run that finished between two polls is still visible next to the `dispatchId` its create returned. Capped at the 100 most recent, so this list is unpaginated and `nextCursor` is always null.",
         "tags": ["Tables"],
         "parameters": [
           {
@@ -2488,7 +2488,7 @@
         ],
         "responses": {
           "200": {
-            "description": "The table's active run dispatches.",
+            "description": "The table's most recent run dispatches.",
             "headers": {
               "X-RateLimit-Limit": {
                 "$ref": "#/components/headers/X-RateLimit-Limit"
@@ -7630,7 +7630,8 @@
             "description": "Workflow or enrichment producer definition."
           },
           "outputColumns": {
-            "minItems": 1,
+            "default": [],
+            "description": "Columns to create for producer outputs. An entry naming a column the table already has attaches that column to the group instead of creating it (its `type` must match), and an output whose column already exists may omit its entry entirely — so `[]` attaches existing columns only.",
             "type": "array",
             "items": {
               "type": "object",
@@ -7665,16 +7666,15 @@
               },
               "required": ["name", "type"],
               "additionalProperties": false
-            },
-            "description": "Columns created for producer outputs."
+            }
           },
           "autoRun": {
             "default": false,
             "description": "Whether to schedule existing rows after group creation.",
             "type": "boolean"
           }
         },
-        "required": ["workspaceId", "group", "outputColumns"],
+        "required": ["workspaceId", "group"],
         "additionalProperties": false,
         "title": "Add table workflow group request",
         "description": "Workspace scope, producer definition, and output columns.",
@@ -10196,7 +10196,7 @@
         "required": ["data", "nextCursor"],
         "additionalProperties": false,
         "title": "Table run dispatch list response",
-        "description": "The table's active run dispatches."
+        "description": "The table's most recent run dispatches, settled ones included."
       },
       "V2MoveTablesData": {
         "type": "object",

apps/docs/openapi-v2-workflows.json

@@ -8383,6 +8383,27 @@
           }
         ]
       },
+      "ImportedWorkflowBlock": {
+        "type": "object",
+        "properties": {
+          "id": {
+            "type": "string",
+            "description": "Block identifier."
+          },
+          "type": {
+            "type": "string",
+            "description": "Registered block type."
+          },
+          "name": {
+            "type": "string",
+            "description": "Block display name."
+          }
+        },
+        "required": ["id", "type", "name"],
+        "additionalProperties": false,
+        "title": "Imported workflow block",
+        "description": "A block the import created in the new workflow."
+      },
       "ImportedWorkflow": {
         "type": "object",
         "properties": {
@@ -8424,6 +8445,13 @@
             "type": "string",
             "description": "ISO 8601 timestamp when the workflow was last updated.",
             "format": "date-time"
+          },
+          "blocks": {
+            "type": "array",
+            "items": {
+              "$ref": "#/components/schemas/ImportedWorkflowBlock"
+            },
+            "description": "Blocks the import created, in payload order. A summary only; `GET /workflows/{workflowId}/state` returns the full graph."
           }
         },
         "required": [
@@ -8433,7 +8461,8 @@
           "workspaceId",
           "folderPath",
           "createdAt",
-          "updatedAt"
+          "updatedAt",
+          "blocks"
         ],
         "additionalProperties": false,
         "title": "Imported workflow",
@@ -8460,7 +8489,24 @@
               "workspaceId": "a91c4b2e-6d3f-4e8a-b5c7-0d9e2f1a8c64",
               "folderPath": "/Operations",
               "createdAt": "2026-05-01T09:00:00.000Z",
-              "updatedAt": "2026-08-09T18:04:11.000Z"
+              "updatedAt": "2026-08-09T18:04:11.000Z",
+              "blocks": [
+                {
+                  "id": "block_start",
+                  "type": "starter",
+                  "name": "Start"
+                },
+                {
+                  "id": "block_triage",
+                  "type": "agent",
+                  "name": "Triage"
+                },
+                {
+                  "id": "block_reply",
+                  "type": "response",
+                  "name": "Reply"
+                }
+              ]
             }
           }
         ]

apps/sim/app/api/v2/tables/[tableId]/dispatches/route.test.ts

@@ -62,6 +62,14 @@ const DISPATCH = {
   completedAt: null,
   cancelledAt: null,
 }
+const COMPLETED_DISPATCH = {
+  ...DISPATCH,
+  id: 'dispatch-2',
+  status: 'complete' as const,
+  processedCount: 13,
+  requestedAt: new Date('2026-01-01T00:10:00Z'),
+  completedAt: new Date('2026-01-01T00:12:00Z'),
+}
 
 function list(query = `?workspaceId=${WORKSPACE_ID}`) {
   const request = new NextRequest(`http://localhost/api/v2/tables/table-1/dispatches${query}`, {
@@ -80,11 +88,18 @@ describe('GET /api/v2/tables/[tableId]/dispatches', () => {
     v2RouteMocks.authenticate.mockResolvedValue(AUTH)
     v2RouteMocks.preauthRate.mockResolvedValue(V2_PREAUTH_RATE_LIMIT_ALLOWED)
     v2RouteMocks.operationRate.mockResolvedValue(V2_OPERATION_RATE_LIMIT_ALLOWED)
-    mocks.listDispatches.mockResolvedValue({ table: { id: 'table-1' }, dispatches: [DISPATCH] })
+    mocks.listDispatches.mockResolvedValue({
+      table: { id: 'table-1' },
+      dispatches: [COMPLETED_DISPATCH, DISPATCH],
+    })
     mocks.startRun.mockResolvedValue({ table: { id: 'table-1' }, dispatchId: 'dispatch-1' })
   })
 
-  it('delegates the canonical table scope and returns the full set', async () => {
+  /**
+   * Settled dispatches are part of the set: a run that completed between two
+   * polls must still show up next to the `dispatchId` its create returned.
+   */
+  it('delegates the canonical table scope and returns the full set, settled dispatches included', async () => {
     const invocation = list()
     const response = await invocation.response
 
@@ -95,11 +110,15 @@ describe('GET /api/v2/tables/[tableId]/dispatches', () => {
       request: invocation.request,
     })
     const body = await response.json()
-    expect(body.data).toHaveLength(1)
+    expect(body.data.map((dispatch: { id: string; status: string }) => dispatch.status)).toEqual([
+      'complete',
+      'pending',
+    ])
+    expect(body.data[0]).toMatchObject({ id: 'dispatch-2', processedCount: 13 })
     expect(body.nextCursor).toBeNull()
   })
 
-  /** The set is dispatcher-bounded, so there is no page for a limit to select. */
+  /** The set is capped by the use case, so there is no page for a limit to select. */
   it('rejects pagination parameters this list does not implement', async () => {
     const response = await list(`?workspaceId=${WORKSPACE_ID}&limit=10`).response
 

apps/sim/app/api/v2/tables/[tableId]/dispatches/route.ts

@@ -13,9 +13,11 @@ export const dynamic = 'force-dynamic'
 export const revalidate = 0
 
 /**
- * Every dispatch still in flight on one table. Unpaged: the dispatcher bounds
- * how many dispatches a table can have active, so `nextCursor` is always null
- * and there is no page for a `limit` to select.
+ * The dispatches on one table, most recent first, settled ones included — a
+ * run that finished between two polls is still listed next to the id its
+ * create returned. Unpaged: the use case caps the list at the most recent
+ * hundred, so `nextCursor` is always null and there is no page for a `limit`
+ * to select.
  */
 export const GET = defineV2JsonRoute({
   contract: v2ListTableDispatchesContract,

apps/sim/app/api/v2/workflows/[workflowId]/runs/[runId]/resume/route.test.ts

@@ -220,6 +220,7 @@ describe('POST /api/v2/workflows/[workflowId]/runs/[runId]/resume', () => {
         workflowId: WORKFLOW_ID,
         status: 'completed',
         output: { approved: true },
+        blockOutputs: null,
         error: null,
         startedAt: '2026-08-05T00:00:00.000Z',
         endedAt: '2026-08-05T00:00:01.000Z',

apps/sim/app/api/v2/workflows/import/route.test.ts

@@ -17,11 +17,19 @@ vi.mock('@/lib/api/server/routes', () => ({
 }))
 
 import { v2WorkflowErrorPolicies } from '@/lib/workflows/api'
-import { importWorkflow } from '@/lib/workflows/application/import-export'
+import {
+  type ImportWorkflowResult,
+  importWorkflow,
+} from '@/lib/workflows/application/import-export'
 import { workflowOperations } from '@/lib/workflows/application/operations'
 import { MAX_IMPORT_BODY_BYTES } from '@/lib/workflows/operations/import-workflow'
 import { POST } from '@/app/api/v2/workflows/import/route'
 
+/** With `defineV2JsonRoute` mocked to return its definition, `POST` is that definition. */
+const definition = POST as unknown as {
+  present: (result: ImportWorkflowResult) => { data: Record<string, unknown> }
+}
+
 describe('/api/v2/workflows/import route definition', () => {
   it('uses authorized admission and preserves the bounded import lifecycle', () => {
     expect(POST).toMatchObject({
@@ -31,4 +39,34 @@ describe('/api/v2/workflows/import route definition', () => {
       parseOptions: { maxBodyBytes: MAX_IMPORT_BODY_BYTES },
     })
   })
+
+  /**
+   * The presenter dropped the imported blocks, so an import that created three
+   * blocks answered with nothing a caller could check short of reading the
+   * state back — and a client filling in `blocks: []` reported an empty import.
+   */
+  it('presents the blocks the import created', () => {
+    const blocks = [
+      { id: 'block-1', type: 'starter', name: 'Start' },
+      { id: 'block-2', type: 'agent', name: 'Classify' },
+      { id: 'block-3', type: 'response', name: 'Reply' },
+    ]
+
+    const { data } = definition.present({
+      workflow: {
+        id: 'workflow-1',
+        name: 'Imported',
+        description: null,
+        workspaceId: 'ws-1',
+        folderId: null,
+        sortOrder: 0,
+        createdAt: new Date('2026-01-01T00:00:00Z'),
+        updatedAt: new Date('2026-01-01T00:00:00Z'),
+        blocks,
+      },
+      folderPath: '/',
+    })
+
+    expect(data).toMatchObject({ id: 'workflow-1', name: 'Imported', folderPath: '/', blocks })
+  })
 })

apps/sim/app/api/v2/workflows/import/route.ts

@@ -32,6 +32,7 @@ export const POST = defineV2JsonRoute({
       folderPath,
       createdAt: workflow.createdAt.toISOString(),
       updatedAt: workflow.updatedAt.toISOString(),
+      blocks: workflow.blocks,
     },
   }),
 })

apps/sim/executor/execution/executor.test.ts

@@ -7,6 +7,7 @@ import { DAGBuilder } from '@/executor/dag/builder'
 import { DAGExecutor } from '@/executor/execution/executor'
 import type { SerializableExecutionState } from '@/executor/execution/types'
 import type { ExecutionContext, ExecutionResult } from '@/executor/types'
+import { RunFromBlockValidationError } from '@/executor/utils/run-from-block'
 import { buildSentinelStartId } from '@/executor/utils/subflow-utils'
 import type { SerializedBlock, SerializedWorkflow } from '@/serializer/types'
 
@@ -329,6 +330,36 @@ describe('DAGExecutor run-from-block snapshot metadata', () => {
     })
     expect(capturedContext?.blockStates.has('unreachable__obranch-0')).toBe(false)
   })
+  it('refuses a start block whose upstream never executed with a typed validation error', async () => {
+    const workflow: SerializedWorkflow = {
+      version: '1',
+      blocks: [
+        createBlock('start', BlockType.STARTER),
+        createBlock('producer', BlockType.FUNCTION),
+        createBlock('consumer', BlockType.FUNCTION),
+      ],
+      connections: [
+        { source: 'start', target: 'producer' },
+        { source: 'producer', target: 'consumer' },
+      ],
+      loops: {},
+      parallels: {},
+    }
+    const executor = new DAGExecutor({ workflow })
+    const sourceSnapshot: SerializableExecutionState = {
+      blockStates: {},
+      executedBlocks: [],
+      blockLogs: [],
+      decisions: { router: {}, condition: {} },
+      completedLoops: [],
+      activeExecutionPath: [],
+    }
+
+    const error = await executor.executeFromBlock('wf', 'consumer', sourceSnapshot).catch((e) => e)
+
+    expect(error).toBeInstanceOf(RunFromBlockValidationError)
+    expect(error.message).toBe('Upstream dependency not executed: producer')
+  })
 })
 
 describe('DAGExecutor resume DAG construction', () => {

apps/sim/executor/execution/executor.ts

@@ -27,6 +27,7 @@ import {
   computeExecutionSets,
   overlayVariableInputs,
   type RunFromBlockContext,
+  RunFromBlockValidationError,
   resolveContainerToSentinelStart,
   validateRunFromBlock,
 } from '@/executor/utils/run-from-block'
@@ -143,7 +144,9 @@ export class DAGExecutor {
     const executedBlocks = new Set(sourceSnapshot.executedBlocks)
     const validation = validateRunFromBlock(startBlockId, dag, executedBlocks)
     if (!validation.valid) {
-      throw new Error(validation.error)
+      throw new RunFromBlockValidationError(
+        validation.error ?? `Cannot run from block: ${startBlockId}`
+      )
     }
 
     const { dirtySet, upstreamSet, reachableUpstreamSet } = computeExecutionSets(dag, startBlockId)

apps/sim/executor/utils/run-from-block.test.ts

@@ -1,7 +1,11 @@
 import { describe, expect, it } from 'vitest'
 import type { DAG, DAGNode } from '@/executor/dag/builder'
 import type { DAGEdge, NodeMetadata } from '@/executor/dag/types'
-import { computeExecutionSets, validateRunFromBlock } from '@/executor/utils/run-from-block'
+import {
+  computeExecutionSets,
+  RunFromBlockValidationError,
+  validateRunFromBlock,
+} from '@/executor/utils/run-from-block'
 import type { SerializedLoop, SerializedParallel } from '@/serializer/types'
 
 /**
@@ -1664,3 +1668,13 @@ describe('upstream block addition/deletion scenarios', () => {
     expect(result.error).toContain('X')
   })
 })
+
+describe('RunFromBlockValidationError', () => {
+  it('is a named Error carrying the validation message verbatim', () => {
+    const error = new RunFromBlockValidationError('Upstream dependency not executed: a')
+
+    expect(error).toBeInstanceOf(Error)
+    expect(error.name).toBe('RunFromBlockValidationError')
+    expect(error.message).toBe('Upstream dependency not executed: a')
+  })
+})