Function restoreScheduleClaim

apps/sim/app/api/schedules/execute/route.ts:242–276

(
  scheduleId: string,
  requestId: string,
  currentClaim: Date,
  activeClaim: Date,
  context: string
)

}

async function restoreScheduleClaim(
  scheduleId: string,
  requestId: string,
  currentClaim: Date,
  activeClaim: Date,
  context: string
): Promise<void> {
  if (currentClaim.getTime() === activeClaim.getTime()) return

  const [restored] = await db
    .update(workflowSchedule)
    .set({ lastQueuedAt: activeClaim, updatedAt: new Date() })
    .where(
      and(
        eq(workflowSchedule.id, scheduleId),
        isNull(workflowSchedule.archivedAt),
        eq(workflowSchedule.lastQueuedAt, currentClaim)
      )
    )
    .returning({ id: workflowSchedule.id })
    .catch((error) => {
      logger.error(`[${requestId}] ${context}`, error)
      throw error
    })

  if (!restored) {
    const error = new Error(`Schedule claim restore did not update schedule ${scheduleId}`)
    logger.warn(`[${requestId}] ${context}`, {
      scheduleId,
      currentClaim: currentClaim.toISOString(),
      activeClaim: activeClaim.toISOString(),
    })
    throw error
  }
}

function getStaleScheduleExecutionCutoff(now: Date): Date {
  return new Date(now.getTime() - STALE_SCHEDULE_CLAIM_MS)