Skip to content

Commit 5387f89

Browse files
soxofaanHansVRP
authored andcommitted
MultiBackendJobManager: don't count "created" jobs as "running"
Note that this behavior was present since beginning of MultiBackendJobManager (b0d100e), but is unnecessary as the resource consumption of "created" jobs is negligible compared to queued or running jobs.
1 parent 615d821 commit 5387f89

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
1616

1717
- Internal reorganization of `openeo.extra.job_management` submodule to ease future development ([#741](https://github.com/Open-EO/openeo-python-client/issues/741))
1818
- `openeo.Connection`: add some more HTTP error codes to the default retry list: `502 Bad Gateway`, `503 Service Unavailable` and `504 Gateway Timeout` ([#835](https://github.com/Open-EO/openeo-python-client/issues/835))
19+
- `MultiBackendJobManager`: don't count "created" jobs as "running"
1920

2021
### Removed
2122

openeo/extra/job_management/_manager.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -553,8 +553,7 @@ def _job_update_loop(
553553
not_started = job_db.get_by_status(statuses=["not_started"], max=200).copy()
554554
if len(not_started) > 0:
555555
# Check number of jobs running at each backend
556-
# TODO: should "created" be included in here? Calling this "running" is quite misleading then.
557-
running = job_db.get_by_status(statuses=["created", "queued", "queued_for_start", "running"])
556+
running = job_db.get_by_status(statuses=["queued", "queued_for_start", "running"])
558557
stats["job_db get_by_status"] += 1
559558
per_backend = running.groupby("backend_name").size().to_dict()
560559
_log.info(f"Running per backend: {per_backend}")

0 commit comments

Comments
 (0)