Fix to store less schedule and clean it up more often

vchain-dev · Nov 13, 2023 · e93f46c · e93f46c
1 parent 071c3bc
commit e93f46c
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 4 deletions.
diff --git a/src/main/kotlin/SchedulePolicy.kt b/src/main/kotlin/SchedulePolicy.kt
@@ -29,4 +29,4 @@ class Cron(
 }
 
 
-val onceAtMidnight = Cron("0 0 * * *")
+val everyHour = Cron("0 * * * *")
diff --git a/src/main/kotlin/Settings.kt b/src/main/kotlin/Settings.kt
@@ -9,7 +9,7 @@ object Settings {
         .seconds
 
     var scheduleTTL: Duration = System.getenv()
-        .getOrDefault("KOTASK_SCHEDULE_CLEANUP_SECONDS", "86400") // 1 day
+        .getOrDefault("KOTASK_SCHEDULE_CLEANUP_SECONDS", "3600") // 1 hour
         .toInt()
         .seconds
 

diff --git a/src/main/kotlin/TaskManager.kt b/src/main/kotlin/TaskManager.kt
@@ -8,7 +8,6 @@ import kotlinx.serialization.Serializable
 import org.slf4j.LoggerFactory
 import cleanScheduleWorker
 import kotlin.time.Duration
-import kotlin.time.Duration.Companion.days
 import kotlin.time.Duration.Companion.hours
 import kotlin.time.Duration.Companion.seconds
 import kotlin.time.DurationUnit
@@ -72,7 +71,7 @@ class TaskManager(
         tasksSchedulers.getOrPut(cleanScheduleWorkloadName) {
             schedulersScope.launch {
                 while (true) {
-                    onceAtMidnight
+                    everyHour
                         .getNextCalls()
                         .takeWhile { it < Clock.System.now() + Settings.schedulingHorizon }
                         .forEach { date ->
Original file line number	Diff line number	Diff line change
Expand Up		@@ -29,4 +29,4 @@ class Cron(
		}


		val onceAtMidnight = Cron("0 0 * * *")
		val everyHour = Cron("0 * * * *")