Function retryScheduleAfterInfraFailure

apps/sim/background/schedule-execution.ts:189–261

({
  payload,
  requestId,
  claimedAt,
  error,
  message,
  cause,
}: {
  payload: ScheduleExecutionPayload
  requestId: string
  claimedAt: Date | null
  error?: unknown
  message?: string
  cause?: Record<string, unknown>
})

}

async function retryScheduleAfterInfraFailure({
  payload,
  requestId,
  claimedAt,
  error,
  message,
  cause,
}: {
  payload: ScheduleExecutionPayload
  requestId: string
  claimedAt: Date | null
  error?: unknown
  message?: string
  cause?: Record<string, unknown>
}) {
  const now = new Date()
  const retryAttempt = (payload.infraRetryCount || 0) + 1
  if (retryAttempt > SCHEDULE_INFRA_RETRY_MAX_ATTEMPTS) {
    logger.error(`[${requestId}] Retryable infrastructure failures exhausted for schedule`, {
      scheduleId: payload.scheduleId,
      workflowId: payload.workflowId,
      retryAttempt,
      maxAttempts: SCHEDULE_INFRA_RETRY_MAX_ATTEMPTS,
      cause: cause ?? describeRetryableInfrastructureError(error),
    })

    const nextRunAt = await determineNextRunAfterError(payload, now, requestId)
    await applyScheduleUpdate(
      payload.scheduleId,
      buildScheduleFailureUpdate(now, nextRunAt),
      requestId,
      `Error updating schedule ${payload.scheduleId} after exhausted infrastructure retries`,
      { expectedLastQueuedAt: claimedAt }
    )
    return
  }

  const retryDelayMs = Math.min(
    SCHEDULE_INFRA_RETRY_MAX_MS,
    Math.round(
      backoffWithJitter(retryAttempt, null, {
        baseMs: SCHEDULE_INFRA_RETRY_BASE_MS,
        maxMs: SCHEDULE_INFRA_RETRY_MAX_MS,
      })
    )
  )
  const nextRetryAt = new Date(now.getTime() + retryDelayMs)
  const failureCause = cause ?? describeRetryableInfrastructureError(error)
  const errorMessage = message ?? (error ? toError(error).message : undefined)

  logger.warn(`[${requestId}] Retryable infrastructure failure during scheduled setup`, {
    scheduleId: payload.scheduleId,
    workflowId: payload.workflowId,
    retryAttempt,
    error: errorMessage,
    retryDelayMs,
    nextRetryAt: nextRetryAt.toISOString(),
    cause: failureCause,