avoid abreviation of number

Author: HansVRP

openeo/extra/job_management/_manager.py

@@ -376,7 +376,7 @@ def run_loop():
                 )
                 > 0
 
-                or (self._worker_pool.num_pending_tasks() > 0)
+                or (self._worker_pool.number_pending_tasks() > 0)
 
                 and not self._stop_thread
             ):
@@ -403,7 +403,7 @@ def stop_job_thread(self, timeout_seconds: Optional[float] = _UNSET):
 
         .. versionadded:: 0.32.0
         """
-        if self._worker_pool is not None: #TODO or thread_pool.num_pending_tasks() > 0 
+        if self._worker_pool is not None or self._worker_pool.number_pending_tasks() > 0:
             self._worker_pool.shutdown()
             self._worker_pool = None
 
@@ -519,7 +519,7 @@ def run_jobs(
                     statuses=["not_started", "created", "queued_for_start", "queued", "running"]
                 ).values()) > 0
 
-            or (self._worker_pool.num_pending_tasks() > 0)
+            or (self._worker_pool.number_pending_tasks() > 0)
 
         ):
             self._job_update_loop(job_db=job_db, start_job=start_job, stats=stats)

openeo/extra/job_management/_thread_worker.py

@@ -254,7 +254,7 @@ def process_futures(self, timeout: Union[float, None] = 0) -> Tuple[List[_TaskRe
         self._future_task_pairs = to_keep
         return results, len(to_keep)
 
-    def num_pending_tasks(self) -> int:
+    def number_pending_tasks(self) -> int:
         """Return the number of tasks that are still pending (not completed)."""
         return len(self._future_task_pairs)
 
@@ -315,12 +315,12 @@ def process_futures(self, timeout: Union[float, None] = 0) -> Tuple[List[_TaskRe
 
         return all_results, remaining_by_pool
 
-    def num_pending_tasks(self, pool_name: Optional[str] = None) -> int:
+    def number_pending_tasks(self, pool_name: Optional[str] = None) -> int:
         if pool_name:
             pool = self._pools.get(pool_name)
-            return pool.num_pending_tasks() if pool else 0
+            return pool.number_pending_tasks() if pool else 0
         else:
-            return sum(pool.num_pending_tasks() for pool in self._pools.values())
+            return sum(pool.number_pending_tasks() for pool in self._pools.values())
 
     def shutdown(self, pool_name: Optional[str] = None) -> None:
         """