Function markJobCompleted

scripts/pipeline/batch-processor.ts:257–262

(jobId: number)

}

async function markJobCompleted(jobId: number): Promise<void> {
  await db
    .update(pipelineJobs)
    .set({ status: "completed", completedAt: new Date() })
    .where(eq(pipelineJobs.id, jobId));
}

async function markJobFailed(jobId: number, error: string, attempts: number, maxAttempts: number): Promise<void> {
  const newStatus = attempts + 1 >= maxAttempts ? "failed" : "pending";