From 215ebceb812ec29a2d21a6149053d4dedd8fb817 Mon Sep 17 00:00:00 2001 From: Stefaan Lippens Date: Fri, 27 Sep 2024 13:58:08 +0200 Subject: [PATCH] job manager: cleaner _job_update_loop related to #614 --- openeo/extra/job_management.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/openeo/extra/job_management.py b/openeo/extra/job_management.py index 84a347e6b..8ef1ae5c3 100644 --- a/openeo/extra/job_management.py +++ b/openeo/extra/job_management.py @@ -333,7 +333,7 @@ def run_loop(): sum(job_db.count_by_status(statuses=["not_started", "created", "queued", "running"]).values()) > 0 and not self._stop_thread ): - self._job_update_loop(df, job_db, start_job) + self._job_update_loop(job_db=job_db, start_job=start_job) # Do sequence of micro-sleeps to allow for quick thread exit for _ in range(int(max(1, self.poll_sleep))): @@ -454,10 +454,10 @@ def run_jobs( job_db.persist(df) while sum(job_db.count_by_status(statuses=["not_started", "created", "queued", "running"]).values()) > 0: - self._job_update_loop(df, job_db, start_job) + self._job_update_loop(job_db=job_db, start_job=start_job) time.sleep(self.poll_sleep) - def _job_update_loop(self, df, job_db, start_job): + def _job_update_loop(self, job_db: JobDatabaseInterface, start_job: Callable[[], BatchJob]): """ Inner loop logic of job management: go through the necessary jobs to check for status updates,