Function processJobItem

apps/sim/app/api/schedules/execute/route.ts:1033–1057

(job: ClaimedJob, queuedAt: Date, requestId: string)

}

async function processJobItem(job: ClaimedJob, queuedAt: Date, requestId: string) {
  const queueTime = job.lastQueuedAt ?? queuedAt
  const payload = {
    scheduleId: job.id,
    cronExpression: job.cronExpression || undefined,
    failedCount: job.failedCount || 0,
    now: queueTime.toISOString(),
  }

  try {
    await executeJobInline(payload)
  } catch (error) {
    logger.error(`[${requestId}] Job execution failed for ${job.id}`, {
      error: toError(error).message,
    })
    await releaseScheduleLock(
      job.id,
      requestId,
      queuedAt,
      `Failed to release lock for job ${job.id}`,
      undefined,
      { expectedLastQueuedAt: queueTime }
    )
  }
}

interface ScheduleTickResult {
  processedCount: number