aboutsummaryrefslogtreecommitdiff
path: root/web/app/job_manager.py
diff options
context:
space:
mode:
authorRaghuram Subramani <raghus2247@gmail.com>2025-05-12 05:25:31 +0000
committerRaghuram Subramani <raghus2247@gmail.com>2025-05-12 05:25:31 +0000
commit9eeb3f87a015a668e837b67410e23c4b34e248af (patch)
tree601c464ed8c04f5aba7a34caa37995e86fde7a7f /web/app/job_manager.py
parentd7b0d4e4f94d928899887407fc131c808e8aa916 (diff)
update
Diffstat (limited to 'web/app/job_manager.py')
-rw-r--r--web/app/job_manager.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/web/app/job_manager.py b/web/app/job_manager.py
index fa486f3..bdbe994 100644
--- a/web/app/job_manager.py
+++ b/web/app/job_manager.py
@@ -20,10 +20,12 @@ class JobManager:
)
def get_jobs(self):
+ queued_jobs = self.q.get_jobs()
+
started_job_ids = self.q.started_job_registry.get_job_ids()
started_jobs = [Job.fetch(job_id, connection=self.redis) for job_id in started_job_ids]
finished_job_ids = self.q.finished_job_registry.get_job_ids()
finished_jobs = [Job.fetch(job_id, connection=self.redis) for job_id in finished_job_ids]
- return started_jobs + finished_jobs
+ return queued_jobs + started_jobs + finished_jobs