Function markClaimedScheduleFailed

apps/sim/app/api/schedules/execute/route.ts:315–336

(
  schedule: DatabaseScheduleExecutionTarget,
  requestId: string,
  expectedLastQueuedAt: Date,
  context: string
)

}

async function markClaimedScheduleFailed(
  schedule: DatabaseScheduleExecutionTarget,
  requestId: string,
  expectedLastQueuedAt: Date,
  context: string
): Promise<void> {
  const now = new Date()
  await db
    .update(workflowSchedule)
    .set(buildScheduleFailureUpdate(now, getScheduleNextRunAt(schedule, now)))
    .where(
      and(
        eq(workflowSchedule.id, schedule.id),
        isNull(workflowSchedule.archivedAt),
        eq(workflowSchedule.lastQueuedAt, expectedLastQueuedAt)
      )
    )
    .catch((error) => {
      logger.error(`[${requestId}] ${context}`, error)
      throw error
    })
}

async function deferClaimedScheduleAfterQueueFailure(
  schedule: ClaimedSchedule,