Function applyScheduleUpdate

apps/sim/background/schedule-execution.ts:134–162

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

}

async function applyScheduleUpdate(
  scheduleId: string,
  updates: WorkflowScheduleUpdate,
  requestId: string,
  context: string,
  options: { expectedLastQueuedAt?: Date | null } = {}
): Promise<boolean> {
  try {
    const claimGuard =
      options.expectedLastQueuedAt === undefined
        ? undefined
        : options.expectedLastQueuedAt === null
          ? isNull(workflowSchedule.lastQueuedAt)
          : eq(workflowSchedule.lastQueuedAt, options.expectedLastQueuedAt)

    const updatedRows = await db
      .update(workflowSchedule)
      .set(updates)
      .where(
        and(eq(workflowSchedule.id, scheduleId), isNull(workflowSchedule.archivedAt), claimGuard)
      )
      .returning({ id: workflowSchedule.id })

    return updatedRows.length > 0
  } catch (error) {
    logger.error(`[${requestId}] ${context}`, error, { cause: describeError(error) })
    throw error
  }
}

export async function releaseScheduleLock(
  scheduleId: string,