Function dispatchDeleteJob

apps/sim/lib/copilot/tools/server/table/user-table.ts:160–195

* Dispatches a background filter-delete for an already-claimed job slot, * mirroring the delete-async route. Same release-on-failed-dispatch guard as * dispatchImportJob.

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

 * {@link dispatchImportJob}.
 */
async function dispatchDeleteJob(params: {
  jobId: string
  tableId: string
  workspaceId: string
  filter: Filter
  cutoff: Date
  maxRows?: number
}): Promise<void> {
  const { jobId, tableId, workspaceId, filter, cutoff, maxRows } = params
  if (isTriggerDevEnabled) {
    try {
      const [{ tableDeleteTask }, { tasks }, { resolveTriggerRegion }] = await Promise.all([
        import('@/background/table-delete'),
        import('@trigger.dev/sdk'),
        import('@/lib/core/async-jobs/region'),
      ])
      await tasks.trigger<typeof tableDeleteTask>(
        'table-delete',
        { jobId, tableId, workspaceId, filter, cutoff: cutoff.toISOString(), maxRows },
        { tags: [`tableId:${tableId}`, `jobId:${jobId}`], region: await resolveTriggerRegion() }
      )
    } catch (error) {
      await releaseJobClaim(tableId, jobId).catch(() => {})
      throw error
    }
  } else {
    runDetached('table-delete', () =>
      runTableDelete({ jobId, tableId, workspaceId, filter, cutoff, maxRows }).catch(
        async (error) => {
          await markTableDeleteFailed(tableId, jobId, error)
          throw error
        }
      )
    )
  }
}

/**
 * Dispatches a background bulk update for an already-claimed job slot, mirroring