Skip to content

Commit f01ab48

Browse files
committed
fixup! PR #839 simplify run/queueing capacity logic a bit
1 parent 41e5512 commit f01ab48

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

openeo/extra/job_management/_manager.py

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@
4343
# TODO: eliminate this module constant (should be part of some constructor interface)
4444
MAX_RETRIES = 50
4545

46+
4647
# Sentinel value to indicate that a parameter was not set
4748
_UNSET = object()
4849

@@ -552,12 +553,9 @@ def _job_update_loop(
552553

553554
total_added = 0
554555
for backend_name in self.backends:
555-
to_add = min(
556-
# How much room is there to start/queue a job?
557-
self.backends[backend_name].queueing_limit - queued_per_backend.get(backend_name, 0),
558-
# How much room is there to run a job?
559-
self.backends[backend_name].parallel_jobs - running_per_backend.get(backend_name, 0),
560-
)
556+
queue_capacity = self.backends[backend_name].queueing_limit - queued_per_backend.get(backend_name, 0)
557+
run_capacity = self.backends[backend_name].parallel_jobs - running_per_backend.get(backend_name, 0)
558+
to_add = min(queue_capacity, run_capacity)
561559
if to_add > 0:
562560
for i in not_started.index[total_added : total_added + to_add]:
563561
self._launch_job(start_job, df=not_started, i=i, backend_name=backend_name, stats=stats)

0 commit comments

Comments
 (0)