Skip to content

Commit 706fafe

Browse files
committed
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 bace886 commit 706fafe

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
@@ -541,8 +541,7 @@ def _job_update_loop(
541541
not_started = job_db.get_by_status(statuses=["not_started"], max=200).copy()
542542
if len(not_started) > 0:
543543
# Check number of jobs running at each backend
544-
# TODO: should "created" be included in here? Calling this "running" is quite misleading then.
545-
running = job_db.get_by_status(statuses=["created", "queued", "queued_for_start", "running"])
544+
running = job_db.get_by_status(statuses=["queued", "queued_for_start", "running"])
546545
stats["job_db get_by_status"] += 1
547546
per_backend = running.groupby("backend_name").size().to_dict()
548547
_log.info(f"Running per backend: {per_backend}")

0 commit comments

Comments
 (0)