Function ownsActiveJob

apps/sim/lib/table/jobs/service.ts:335–341

Shared WHERE for terminal transitions: this job run, and still in-flight (write-once).

(tableId: string, jobId: string)

/** Shared WHERE for terminal transitions: this job run, and still in-flight (write-once). */
function ownsActiveJob(tableId: string, jobId: string) {
  return and(
    eq(tableJobs.id, jobId),
    eq(tableJobs.tableId, tableId),
    eq(tableJobs.status, 'running')
  )
}

/**
 * Marks a job complete. No-op unless it's still this in-flight run. Returns whether it