Function updateJobProgress

apps/sim/lib/table/jobs/service.ts:181–192

(
  tableId: string,
  rowsProcessed: number,
  jobId: string
)

 * in-flight job.
 */
export async function updateJobProgress(
  tableId: string,
  rowsProcessed: number,
  jobId: string
): Promise<boolean> {
  const updated = await db
    .update(tableJobs)
    .set({ rowsProcessed, updatedAt: new Date() })
    .where(ownsActiveJob(tableId, jobId))
    .returning({ id: tableJobs.id })
  return updated.length > 0
}

/**
 * Reads the persisted progress of an in-flight job this worker still owns (`null` when the job