Function releaseScheduleLock

apps/sim/background/schedule-execution.ts:164–182

(
  scheduleId: string,
  requestId: string,
  now: Date,
  context: string,
  nextRunAt?: Date | null,
  options: { expectedLastQueuedAt?: Date | null } = {}
)

}

export async function releaseScheduleLock(
  scheduleId: string,
  requestId: string,
  now: Date,
  context: string,
  nextRunAt?: Date | null,
  options: { expectedLastQueuedAt?: Date | null } = {}
): Promise<boolean> {
  const updates: WorkflowScheduleUpdate = {
    updatedAt: now,
    lastQueuedAt: null,
  }

  if (nextRunAt) {
    updates.nextRunAt = nextRunAt
  }

  return applyScheduleUpdate(scheduleId, updates, requestId, context, options)
}

function getScheduleClaimedAt(payload: ScheduleExecutionPayload): Date | null {
  const claimedAt = new Date(payload.now)