Skip to content

Commit 1f027cd

Browse files
committed
do not expose number of remaining jobs
1 parent 02eb78b commit 1f027cd

File tree

2 files changed

+4
-6
lines changed

2 files changed

+4
-6
lines changed

openeo/extra/job_management/_manager.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -704,7 +704,7 @@ def _process_threadworker_updates(
704704
:param stats: Dictionary accumulating statistic counters
705705
"""
706706
# Retrieve completed task results immediately
707-
results, _ = worker_pool.process_futures(timeout=0)
707+
results = worker_pool.process_futures(timeout=0)
708708

709709
# Collect update dicts
710710
updates: List[Dict[str, Any]] = []

openeo/extra/job_management/_thread_worker.py

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -252,7 +252,7 @@ def process_futures(self, timeout: Union[float, None] = 0) -> Tuple[List[_TaskRe
252252
_log.info("process_futures: %d tasks done, %d tasks remaining", len(results), len(to_keep))
253253

254254
self._future_task_pairs = to_keep
255-
return results, len(to_keep)
255+
return results
256256

257257
def number_pending_tasks(self) -> int:
258258
"""Return the number of tasks that are still pending (not completed)."""
@@ -306,14 +306,12 @@ def process_futures(self, timeout: Union[float, None] = 0) -> Tuple[List[_TaskRe
306306
Returns: (all_results, dict of remaining tasks per pool)
307307
"""
308308
all_results = []
309-
remaining_by_pool = {}
310309

311310
for pool_name, pool in self._pools.items():
312-
results, remaining = pool.process_futures(timeout)
311+
results = pool.process_futures(timeout)
313312
all_results.extend(results)
314-
remaining_by_pool[pool_name] = remaining
315313

316-
return all_results, remaining_by_pool
314+
return all_results
317315

318316
def number_pending_tasks(self, pool_name: Optional[str] = None) -> int:
319317
if pool_name:

0 commit comments

Comments
 (0)