Function executeScheduleJob

apps/sim/background/schedule-execution.ts:605–979

(payload: ScheduleExecutionPayload)

}

export async function executeScheduleJob(payload: ScheduleExecutionPayload) {
  const correlation = buildScheduleCorrelation(payload)
  const executionId = correlation.executionId
  const requestId = correlation.requestId
  const claimedAt = getScheduleClaimedAt(payload)
  const now = new Date()
  const scheduledFor = payload.scheduledFor ? new Date(payload.scheduledFor) : null

  return runWithRequestContext({ requestId }, async () => {
    logger.info(`[${requestId}] Starting schedule execution`, {
      scheduleId: payload.scheduleId,
      workflowId: payload.workflowId,
      executionId,
      scheduledFor: scheduledFor?.toISOString(),
      claimedAt: claimedAt?.toISOString(),
    })

    const releaseClaim = (
      releaseNow: Date,
      context: string,
      nextRunAt?: Date | null
    ): Promise<boolean> =>
      releaseScheduleLock(payload.scheduleId, requestId, releaseNow, context, nextRunAt, {
        expectedLastQueuedAt: claimedAt,
      })

    const updateClaimedSchedule = (
      updates: WorkflowScheduleUpdate,
      context: string
    ): Promise<boolean> =>
      applyScheduleUpdate(payload.scheduleId, updates, requestId, context, {
        expectedLastQueuedAt: claimedAt,
      })

    try {
      const [scheduleRecord] = await db
        .select({
          id: workflowSchedule.id,
          workflowId: workflowSchedule.workflowId,
          deploymentVersionId: workflowSchedule.deploymentVersionId,
          status: workflowSchedule.status,
          archivedAt: workflowSchedule.archivedAt,
          lastQueuedAt: workflowSchedule.lastQueuedAt,
        })
        .from(workflowSchedule)
        .where(eq(workflowSchedule.id, payload.scheduleId))
        .limit(1)

      if (!scheduleRecord) {
        logger.info(`[${requestId}] Schedule no longer exists, skipping execution`, {
          scheduleId: payload.scheduleId,
        })
        return
      }

      if (
        claimedAt &&
        (!scheduleRecord.lastQueuedAt ||