Function dispatchUpdateJob

apps/sim/lib/copilot/tools/server/table/user-table.ts:202–238

* Dispatches a background bulk update for an already-claimed job slot, mirroring * dispatchDeleteJob: trigger.dev when enabled, detached worker otherwise, releasing the * slot on a failed dispatch.

(params: {
  jobId: string
  tableId: string
  workspaceId: string
  filter: Filter
  data: RowData
  cutoff: Date
  maxRows?: number
})

 * slot on a failed dispatch.
 */
async function dispatchUpdateJob(params: {
  jobId: string
  tableId: string
  workspaceId: string
  filter: Filter
  data: RowData
  cutoff: Date
  maxRows?: number
}): Promise<void> {
  const { jobId, tableId, workspaceId, filter, data, cutoff, maxRows } = params
  if (isTriggerDevEnabled) {
    try {
      const [{ tableUpdateTask }, { tasks }, { resolveTriggerRegion }] = await Promise.all([
        import('@/background/table-update'),
        import('@trigger.dev/sdk'),
        import('@/lib/core/async-jobs/region'),
      ])
      await tasks.trigger<typeof tableUpdateTask>(
        'table-update',
        { jobId, tableId, workspaceId, filter, data, cutoff: cutoff.toISOString(), maxRows },
        { tags: [`tableId:${tableId}`, `jobId:${jobId}`], region: await resolveTriggerRegion() }
      )
    } catch (error) {
      await releaseJobClaim(tableId, jobId).catch(() => {})
      throw error
    }
  } else {
    runDetached('table-update', () =>
      runTableUpdate({ jobId, tableId, workspaceId, filter, data, cutoff, maxRows }).catch(
        async (error) => {
          await markTableUpdateFailed(tableId, jobId, error)
          throw error
        }
      )
    )
  }
}

/**
 * Loads the live workflow state and flattens it into pickable outputs. Used