Function markJobProcessing

scripts/pipeline/batch-processor.ts:250–255

(jobId: number)

}

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

async function markJobCompleted(jobId: number): Promise<void> {
  await db