Catalog hides sunset blocks unless includeSunset; enrichment get returns the group's run state and outputs; knowledge upload prints the document fields; docs chunks titled by page not nav link; logs carry hasHandledErrors and opt-in handledErrorRuns; outputTable receipt keeps stdout

Author: Sg312

apps/docs/openapi-v2-logs.json

@@ -218,6 +218,16 @@
               "minLength": 1
             }
           },
+          {
+            "name": "includeHandledErrors",
+            "in": "query",
+            "required": false,
+            "description": "Whether `level=error` also selects runs that finished at `info` after a block error was recovered by an error path. Off by default: such a run succeeded, so it is an error only to a caller auditing error handling. Every row reports `hasHandledErrors` whether or not this is set. Job runs carry no block trace, so the flag never widens that branch.",
+            "schema": {
+              "description": "Whether `level=error` also selects runs that finished at `info` after a block error was recovered by an error path. Off by default: such a run succeeded, so it is an error only to a caller auditing error handling. Every row reports `hasHandledErrors` whether or not this is set. Job runs carry no block trace, so the flag never widens that branch.",
+              "type": "boolean"
+            }
+          },
           {
             "name": "status",
             "in": "query",
@@ -477,6 +487,16 @@
               "description": "Severity level to include."
             }
           },
+          {
+            "name": "includeHandledErrors",
+            "in": "query",
+            "required": false,
+            "description": "Whether runs with a handled block error are counted as `handledErrorRuns`, and whether `level=error` also selects them. Off by default: counting them scans each run’s stored trace.",
+            "schema": {
+              "description": "Whether runs with a handled block error are counted as `handledErrorRuns`, and whether `level=error` also selects them. Off by default: counting them scans each run’s stored trace.",
+              "type": "boolean"
+            }
+          },
           {
             "name": "startDate",
             "in": "query",
@@ -951,6 +971,10 @@
             ],
             "description": "Files the run produced, or null when none are recorded. Only the run's own output files appear; input attachments a caller supplied are addressed through the files API instead."
           },
+          "hasHandledErrors": {
+            "type": "boolean",
+            "description": "Whether a block in the run errored and was recovered by an error path. Such a run keeps `level: info`, so this is the only place the handled error shows at run level; pass `includeHandledErrors=true` with `level=error` to list these runs. Always false for a job run."
+          },
           "workflow": {
             "type": "object",
             "properties": {
@@ -1012,7 +1036,8 @@
           "endedAt",
           "totalDurationMs",
           "cost",
-          "files"
+          "files",
+          "hasHandledErrors"
         ],
         "additionalProperties": false,
         "title": "Execution log summary",
@@ -1260,6 +1285,7 @@
                 "cost": {
                   "total": 0.0032
                 },
+                "hasHandledErrors": false,
                 "files": [
                   {
                     "id": "f1c3a7d0-4b52-4a8e-9f61-2d7c8b3e5a04",
@@ -1798,6 +1824,10 @@
             "type": "number",
             "description": "Runs in the window that errored."
           },
+          "handledErrorRuns": {
+            "description": "Runs in the window in which a block errored and was recovered by an error path. Such runs count as successful in every other figure. Present only when `includeHandledErrors=true`.",
+            "type": "number"
+          },
           "avgLatency": {
             "type": "number",
             "description": "Mean run duration in milliseconds across the window, weighted by run count."

apps/docs/openapi-v2-resources.json

@@ -3639,6 +3639,16 @@
               "enum": ["builtin", "custom"]
             }
           },
+          {
+            "name": "includeSunset",
+            "in": "query",
+            "required": false,
+            "description": "Include `legacy` and `deprecated` blocks. Off by default: a sunset block keeps executing where it is already placed, but it is not offered for new authoring. Each returned entry carries `sunset.replacedBy`, the block to build with instead.",
+            "schema": {
+              "description": "Include `legacy` and `deprecated` blocks. Off by default: a sunset block keeps executing where it is already placed, but it is not offered for new authoring. Each returned entry carries `sunset.replacedBy`, the block to build with instead.",
+              "type": "boolean"
+            }
+          },
           {
             "name": "sortBy",
             "in": "query",

apps/docs/openapi-v2-tables.json

@@ -2637,8 +2637,8 @@
       },
       "get": {
         "operationId": "getRowEnrichment",
-        "summary": "Get Enrichment Run Detail",
-        "description": "Retrieve the provider cascade behind one enrichment cell: every configured provider in cascade order, each one's status, hosted-key cost, and duration, plus which provider produced the match. `null` means the cell has never run, or ran before cascade detail was recorded — distinct from a `404`, which means the table, row, or group does not exist.",
+        "summary": "Get Row Group Run",
+        "description": "Retrieve one workflow or enrichment group's outcome on one row: the run state `includeRunState` reports on the row endpoints (`status`, `error`, `workflowId`, `executionId`, …), the group's output cells keyed by column name, and — for an enrichment group — the provider cascade behind them: every configured provider in cascade order, each one's status, hosted-key cost, and duration, plus which provider produced the match. A row that exists always answers; `runState: null` means the group has never run for it, and `cascade: null` that no provider breakdown was recorded. A `404` means the table, row, or group does not exist.",
         "tags": ["Tables"],
         "parameters": [
           {
@@ -2688,7 +2688,7 @@
         ],
         "responses": {
           "200": {
-            "description": "The enrichment run detail, or null when none was recorded.",
+            "description": "The run state, output cells, and provider cascade for the group on the row.",
             "headers": {
               "X-RateLimit-Limit": {
                 "$ref": "#/components/headers/X-RateLimit-Limit"
@@ -9983,10 +9983,29 @@
         "title": "Enrichment provider outcome",
         "description": "One provider's result within an enrichment cascade."
       },
-      "V2RowEnrichmentResponse": {
+      "V2RowGroupEnrichment": {
         "type": "object",
         "properties": {
-          "data": {
+          "groupId": {
+            "type": "string",
+            "description": "Workflow or enrichment group this answers for."
+          },
+          "runState": {
+            "anyOf": [
+              {
+                "$ref": "#/components/schemas/V2TableRowRunState"
+              },
+              {
+                "type": "null"
+              }
+            ],
+            "description": "Most recent run of this group on this row — the same shape `includeRunState` reports — or null when the group has never run for the row."
+          },
+          "outputs": {
+            "description": "The group's output cells keyed by column name. A column the run has not populated is null.",
+            "$ref": "#/components/schemas/V2TableRowData"
+          },
+          "cascade": {
             "anyOf": [
               {
                 "$ref": "#/components/schemas/V2EnrichmentRunDetail"
@@ -9995,13 +10014,26 @@
                 "type": "null"
               }
             ],
-            "description": "Response data."
+            "description": "Provider cascade behind the cell, or null when none was recorded — a manual workflow group, a group that has not run, or a run predating the breakdown."
+          }
+        },
+        "required": ["groupId", "runState", "outputs", "cascade"],
+        "additionalProperties": false,
+        "title": "Row group enrichment",
+        "description": "Run state, output cells, and provider cascade for one group on one row."
+      },
+      "V2RowEnrichmentResponse": {
+        "type": "object",
+        "properties": {
+          "data": {
+            "description": "Response data.",
+            "$ref": "#/components/schemas/V2RowGroupEnrichment"
           }
         },
         "required": ["data"],
         "additionalProperties": false,
         "title": "Row enrichment response",
-        "description": "Provider cascade, cost, and timing for one enrichment cell."
+        "description": "Run state, output cells, and provider cascade for one group on one row."
       },
       "V2TableRunDispatch": {
         "type": "object",

apps/sim/app/api/v2/blocks/route.test.ts

@@ -71,6 +71,7 @@ function blockCursor({
   category,
   capability,
   source,
+  includeSunset = false,
   sortBy = 'id',
   sortOrder = 'asc',
 }: {
@@ -79,6 +80,7 @@ function blockCursor({
   category?: string
   capability?: string
   source?: string
+  includeSunset?: boolean
   sortBy?: string
   sortOrder?: string
 }): string {
@@ -90,6 +92,7 @@ function blockCursor({
       category,
       capability,
       source,
+      includeSunset,
     }),
     offset
   )
@@ -123,6 +126,7 @@ describe('/api/v2/blocks', () => {
         category: undefined,
         capability: undefined,
         source: undefined,
+        includeSunset: false,
         sortBy: 'id',
         sortOrder: 'asc',
         limit: 50,
@@ -133,6 +137,25 @@ describe('/api/v2/blocks', () => {
     })
   })
 
+  it('asks for sunset blocks only when includeSunset is set, and stamps it into the cursor', async () => {
+    const response = await GET(
+      request(`/api/v2/blocks?workspaceId=${WORKSPACE_ID}&includeSunset=true`)
+    )
+
+    expect(response.status).toBe(200)
+    expect(mocks.list).toHaveBeenCalledWith(
+      expect.objectContaining({ input: expect.objectContaining({ includeSunset: true }) })
+    )
+
+    const cursor = blockCursor({ offset: 2 })
+    const replayed = await GET(
+      request(
+        `/api/v2/blocks?workspaceId=${WORKSPACE_ID}&includeSunset=true&cursor=${encodeURIComponent(cursor)}`
+      )
+    )
+    expect(replayed.status).toBe(400)
+  })
+
   it('resumes from the offset cursor and mints the next one while pages remain', async () => {
     mocks.list.mockResolvedValue({ entries: [summary], hasMore: true, offset: 2, limit: 2 })
     const cursor = blockCursor({ offset: 2 })

apps/sim/app/api/v2/blocks/route.ts

@@ -17,6 +17,7 @@ function blockCursorFilters(query: V2ListBlocksQuery) {
     category: query.category,
     capability: query.capability,
     source: query.source,
+    includeSunset: query.includeSunset,
   })
 }
 

apps/sim/app/api/v2/knowledge/[knowledgeBaseId]/documents/uploads/[uploadId]/complete/route.test.ts

@@ -41,33 +41,6 @@ vi.mock('@/lib/core/telemetry', () => ({
   PlatformEvents: { knowledgeBaseDocumentsUploaded: mocks.platformEvent },
 }))
 vi.mock('@/lib/posthog/server', () => ({ captureServerEvent: mocks.captureServerEvent }))
-vi.mock('@/app/api/v2/knowledge/[knowledgeBaseId]/documents/uploads/utils', () => ({
-  toV2KnowledgeDocumentUpload: (_session: unknown, document: { id: string } | null) => ({
-    id: 'upload-1',
-    knowledgeBaseId: 'kb-1',
-    status: 'completed',
-    name: 'guide.pdf',
-    contentType: 'application/pdf',
-    size: 1024,
-    expiresAt: '2026-08-04T21:00:00.000Z',
-    error: null,
-    document: document
-      ? {
-          id: document.id,
-          knowledgeBaseId: 'kb-1',
-          filename: 'guide.pdf',
-          fileSize: 1024,
-          mimeType: 'application/pdf',
-          processingStatus: 'pending',
-          chunkCount: 0,
-          tokenCount: 0,
-          characterCount: 0,
-          enabled: true,
-          createdAt: '2026-08-03T21:01:00.000Z',
-        }
-      : null,
-  }),
-}))
 
 import { POST } from '@/app/api/v2/knowledge/[knowledgeBaseId]/documents/uploads/[uploadId]/complete/route'
 
@@ -84,8 +57,19 @@ const DOCUMENT = {
   enabled: true,
   uploadedAt: new Date('2026-08-03T21:01:00.000Z'),
 }
+/** The session as the completion use case hands it back, in storage shape. */
+const SESSION = {
+  id: 'upload-1',
+  knowledgeBaseId: 'kb-1',
+  status: 'completed',
+  fileName: 'guide.pdf',
+  contentType: 'application/pdf',
+  fileSize: 1024,
+  expiresAt: new Date('2026-08-04T21:00:00.000Z'),
+  error: null,
+}
 const RESULT = {
-  session: { id: 'upload-1' },
+  session: SESSION,
   value: { document: DOCUMENT, created: true, knowledgeBaseName: 'Docs' },
   alreadyCompleted: false,
   workspaceId: WORKSPACE_ID,
@@ -160,6 +144,32 @@ describe('POST knowledge-document upload completion', () => {
     expect(await response.json()).toMatchObject({ data: { document: { id: 'upload-1' } } })
   })
 
+  /**
+   * `knowledge documents upload` answered `filename: null, processingStatus: null`:
+   * the created row must come back under its own names, freshly `pending`
+   * with no chunks yet, not only as a session receipt.
+   */
+  it('publishes the created row with its filename, pending status, and zero chunks', async () => {
+    mocks.completeUpload.mockResolvedValue(RESULT)
+
+    const response = await request().response
+    const body = await response.json()
+
+    expect(response.status).toBe(200)
+    expect(body.data).toMatchObject({
+      id: 'upload-1',
+      status: 'completed',
+      name: 'guide.pdf',
+      document: {
+        id: 'upload-1',
+        filename: 'guide.pdf',
+        processingStatus: 'pending',
+        chunkCount: 0,
+        createdAt: '2026-08-03T21:01:00.000Z',
+      },
+    })
+  })
+
   it('does not duplicate analytics for an idempotent completion retry', async () => {
     mocks.completeUpload.mockResolvedValue({
       ...RESULT,