setup result ttl for healthcheck scheduler (#440)

scality · Sep 14, 2023 · c847012 · c847012
1 parent 3003475
commit c847012
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/runner_manager/jobs/startup.py b/runner_manager/jobs/startup.py
@@ -64,6 +64,11 @@ def bootstrap_healthchecks(
                 "group": group.name,
             },
             interval=settings.healthcheck_interval.total_seconds(),
+            # As described in the documentation of rq-scheduler, the result_ttl
+            # must be set to a value greater than the interval, otherwise
+            # the entry job with the details will expire and the job will not get
+            # rescheduled.
+            result_ttl=settings.healthcheck_interval.total_seconds() * 10,
             repeat=None,
         )
 

diff --git a/tests/api/test_lifespan.py b/tests/api/test_lifespan.py
@@ -1,12 +1,13 @@
 from rq import Queue
-from rq.job import JobStatus
+from rq.job import Job, JobStatus
 from starlette.testclient import TestClient
 
 from runner_manager.jobs.startup import startup
 
 
 def enqueue_startup(queue: Queue) -> bool:
     for job in queue.get_jobs():
+        job: Job
         if startup == job.func:
             if job.get_status() == JobStatus.QUEUED:
                 queue.enqueue_job(job)