From cb4278e71b6536a048f826403186cb62e6ba30ec Mon Sep 17 00:00:00 2001 From: Arshadul Monir Date: Sun, 26 Apr 2026 14:44:07 -0400 Subject: [PATCH] 966: Added delay to cron jobs with failed tests --- .../codebloom/scheduled/auth/LeetcodeAuthStealer.java | 2 +- .../codebloom/scheduled/discord/WeeklyLeaderboard.java | 3 ++- .../scheduled/leetcode/AttachTagsToExistingQuestion.java | 2 +- .../scheduled/leetcode/LeetcodeQuestionProcessService.java | 2 +- .../codebloom/scheduled/metrics/AddUserMetricsService.java | 2 +- 5 files changed, 6 insertions(+), 5 deletions(-) diff --git a/src/main/java/org/patinanetwork/codebloom/scheduled/auth/LeetcodeAuthStealer.java b/src/main/java/org/patinanetwork/codebloom/scheduled/auth/LeetcodeAuthStealer.java index cbefd4fb0..35f5f9289 100644 --- a/src/main/java/org/patinanetwork/codebloom/scheduled/auth/LeetcodeAuthStealer.java +++ b/src/main/java/org/patinanetwork/codebloom/scheduled/auth/LeetcodeAuthStealer.java @@ -68,7 +68,7 @@ public LeetcodeAuthStealer( * authentication key from Leetcode. That code is stored in the database and can then be used to run authenticated * queries such as being used to retrieve code from our user submissions. */ - @Scheduled(initialDelay = 0, fixedDelay = 1, timeUnit = TimeUnit.HOURS) + @Scheduled(initialDelay = 0, fixedDelay = 60, timeUnit = TimeUnit.MINUTES) public void stealAuthCookie() { boolean acquired = LOCK.writeLock().tryLock(); if (!acquired) { diff --git a/src/main/java/org/patinanetwork/codebloom/scheduled/discord/WeeklyLeaderboard.java b/src/main/java/org/patinanetwork/codebloom/scheduled/discord/WeeklyLeaderboard.java index b5d2975e7..738af7777 100644 --- a/src/main/java/org/patinanetwork/codebloom/scheduled/discord/WeeklyLeaderboard.java +++ b/src/main/java/org/patinanetwork/codebloom/scheduled/discord/WeeklyLeaderboard.java @@ -1,6 +1,7 @@ package org.patinanetwork.codebloom.scheduled.discord; import java.time.LocalDateTime; +import java.util.concurrent.TimeUnit; import lombok.extern.slf4j.Slf4j; import org.patinanetwork.codebloom.common.components.DiscordClubManager; import org.patinanetwork.codebloom.common.db.models.weekly.WeeklyMessage; @@ -23,7 +24,7 @@ public class WeeklyLeaderboard { this.weeklyMessageRepository = weeklyMessageRepository; } - @Scheduled(initialDelay = 0, fixedDelay = 1000 * 60 * 60) + @Scheduled(initialDelay = 0, fixedDelay = 1000 * 60 * 60, timeUnit = TimeUnit.HOURS) public void sendWeeklyLeaderboard() { WeeklyMessage weeklyMessage = weeklyMessageRepository.getLatestWeeklyMessage(); diff --git a/src/main/java/org/patinanetwork/codebloom/scheduled/leetcode/AttachTagsToExistingQuestion.java b/src/main/java/org/patinanetwork/codebloom/scheduled/leetcode/AttachTagsToExistingQuestion.java index 8ac7d4eae..a61ca217f 100644 --- a/src/main/java/org/patinanetwork/codebloom/scheduled/leetcode/AttachTagsToExistingQuestion.java +++ b/src/main/java/org/patinanetwork/codebloom/scheduled/leetcode/AttachTagsToExistingQuestion.java @@ -33,7 +33,7 @@ public AttachTagsToExistingQuestion( this.leetcodeClient = throttledLeetcodeClient; } - @Scheduled(initialDelay = 0, fixedDelay = 120, timeUnit = TimeUnit.MINUTES) + @Scheduled(initialDelay = 15, fixedDelay = 120, timeUnit = TimeUnit.MINUTES) void attachTagsToExistingQuestions() { log.info("Attempting to attach tags to existing questions that are missing any..."); List questions = questionRepository.getAllQuestionsWithNoTopics(); diff --git a/src/main/java/org/patinanetwork/codebloom/scheduled/leetcode/LeetcodeQuestionProcessService.java b/src/main/java/org/patinanetwork/codebloom/scheduled/leetcode/LeetcodeQuestionProcessService.java index f8b1aa37e..7093bece4 100644 --- a/src/main/java/org/patinanetwork/codebloom/scheduled/leetcode/LeetcodeQuestionProcessService.java +++ b/src/main/java/org/patinanetwork/codebloom/scheduled/leetcode/LeetcodeQuestionProcessService.java @@ -79,7 +79,7 @@ private List claimBatch(final int maxSize) { return jobRepository.findIncompleteJobs(maxSize); } - @Scheduled(initialDelay = 0, fixedDelay = 30, timeUnit = TimeUnit.MINUTES) + @Scheduled(initialDelay = 15, fixedDelay = 30, timeUnit = TimeUnit.MINUTES) @Async public CompletableFuture drainQueue() { if (!LOCK.tryLock()) { diff --git a/src/main/java/org/patinanetwork/codebloom/scheduled/metrics/AddUserMetricsService.java b/src/main/java/org/patinanetwork/codebloom/scheduled/metrics/AddUserMetricsService.java index 19c46c0ac..60fd47b6f 100644 --- a/src/main/java/org/patinanetwork/codebloom/scheduled/metrics/AddUserMetricsService.java +++ b/src/main/java/org/patinanetwork/codebloom/scheduled/metrics/AddUserMetricsService.java @@ -38,7 +38,7 @@ public AddUserMetricsService( this.userMetricsRepository = userMetricsRepository; } - @Scheduled(initialDelay = 0, fixedDelay = 30, timeUnit = TimeUnit.MINUTES) + @Scheduled(initialDelay = 15, fixedDelay = 30, timeUnit = TimeUnit.MINUTES) public void congregateUserMetrics() { try { Optional recentMetricsTask =