Reduce lock time for tracking Batch and Session apps (#485)

exacaster · May 10, 2023 · 58fe9f9 · 58fe9f9
1 parent 74ff2ae
commit 58fe9f9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/server/src/main/java/com/exacaster/lighter/application/batch/BatchHandler.java b/server/src/main/java/com/exacaster/lighter/application/batch/BatchHandler.java
@@ -78,7 +78,7 @@ private Integer getMaxSlotsForNewJobs() {
         return maxSlotsForNewJobs;
     }
 
-    @SchedulerLock(name = "trackRunning")
+    @SchedulerLock(name = "trackRunning", lockAtMostFor = "1m")
     @Scheduled(fixedDelay = "30s")
     public void trackRunning() throws InterruptedException {
         assertLocked();

diff --git a/server/src/main/java/com/exacaster/lighter/application/sessions/SessionHandler.java b/server/src/main/java/com/exacaster/lighter/application/sessions/SessionHandler.java
@@ -92,7 +92,7 @@ private Waitable launchSession(Application session) {
         return launch(session, error -> statusTracker.processApplicationError(session, error));
     }
 
-    @SchedulerLock(name = "trackRunningSessions")
+    @SchedulerLock(name = "trackRunningSessions", lockAtMostFor = "1m")
     @Scheduled(fixedRate = "2m")
     public void trackRunning() {
         assertLocked();