improvement(mothership): user_table speed parity — limit bounds, async import/delete/update jobs

- query_rows / filter ops clamp limit to the contract maxes; query_rows
  skips execution metadata.
- import_file / create_from_file (large CSV/TSV) and delete_rows_by_filter
  (>1000 unbounded matches) dispatch background table jobs, claiming the
  per-table job slot; inline paths claim the slot too.
- update_rows_by_filter now escalates the same way: >1000 unbounded matches
  run as a background table job (new 'update' job type + runTableUpdate worker
  + tableUpdateTask), so a broad update on a huge table no longer loads every
  row into the request. Best-effort/non-atomic and skips workflow recompute
  (documented); unique-column patches stay inline. Pagination is limit/offset.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

Author: TheodoreSpeaks

apps/sim/background/table-update.ts

@@ -0,0 +1,38 @@
+import { task } from '@trigger.dev/sdk'
+import {
+  markTableUpdateFailed,
+  runTableUpdate,
+  type TableUpdatePayload,
+} from '@/lib/table/update-runner'
+
+/**
+ * `TableUpdatePayload` with the cutoff as an ISO string — task payloads cross a JSON boundary, so
+ * the Date is rehydrated in `run` rather than trusting payload serialization.
+ */
+export interface TableUpdateTaskPayload extends Omit<TableUpdatePayload, 'cutoff'> {
+  cutoff: string
+}
+
+/**
+ * Trigger.dev wrapper around `runTableUpdate`. Errors propagate out of `run` so the retry policy
+ * fires; the job is marked failed only in `onFailure`, after the final attempt. Retry-safe: the
+ * worker keysets by id with a `created_at <= cutoff` floor and the JSONB-merge patch is idempotent
+ * (re-applying the same patch to an already-patched row is a no-op), so a retried attempt re-walks
+ * and re-applies whatever remains. The `table_jobs` ownership gate stops a retried run that lost
+ * the job within one page.
+ */
+export const tableUpdateTask = task({
+  id: 'table-update',
+  machine: 'small-1x',
+  retry: { maxAttempts: 3 },
+  queue: {
+    name: 'table-update',
+    concurrencyLimit: 10,
+  },
+  run: async (payload: TableUpdateTaskPayload) => {
+    await runTableUpdate({ ...payload, cutoff: new Date(payload.cutoff) })
+  },
+  onFailure: async ({ payload, error }) => {
+    await markTableUpdateFailed(payload.tableId, payload.jobId, error)
+  },
+})

apps/sim/lib/copilot/generated/tool-catalog-v1.ts

@@ -3958,7 +3958,8 @@ export const UserTable: ToolCatalogEntry = {
           },
           limit: {
             type: 'number',
-            description: 'Maximum rows to return or affect (optional, default 100)',
+            description:
+              'Maximum rows to return or affect (optional; default 100, max 1000). For delete_rows_by_filter and update_rows_by_filter, omitting it lets matches above 1000 run as a background job.',
           },
           mapping: {
             type: 'object',
@@ -4011,7 +4012,7 @@ export const UserTable: ToolCatalogEntry = {
           },
           offset: {
             type: 'number',
-            description: 'Number of rows to skip (optional for query_rows, default 0)',
+            description: 'Number of rows to skip for query_rows pagination (optional, default 0).',
           },
           outputColumnNames: {
             type: 'object',

apps/sim/lib/copilot/generated/tool-schemas-v1.ts

@@ -3686,7 +3686,8 @@ export const TOOL_RUNTIME_SCHEMAS: Record<string, ToolRuntimeSchemaEntry> = {
             },
             limit: {
               type: 'number',
-              description: 'Maximum rows to return or affect (optional, default 100)',
+              description:
+                'Maximum rows to return or affect (optional; default 100, max 1000). For delete_rows_by_filter and update_rows_by_filter, omitting it lets matches above 1000 run as a background job.',
             },
             mapping: {
               type: 'object',
@@ -3745,7 +3746,8 @@ export const TOOL_RUNTIME_SCHEMAS: Record<string, ToolRuntimeSchemaEntry> = {
             },
             offset: {
               type: 'number',
-              description: 'Number of rows to skip (optional for query_rows, default 0)',
+              description:
+                'Number of rows to skip for query_rows pagination (optional, default 0).',
             },
             outputColumnNames: {
               type: 'object',