diff --git a/CHANGELOG.md b/CHANGELOG.md index 4477c64..b608b6d 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -8,6 +8,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ### Added - Added support for `FetchType.POINT` in Sentinel-1 orbit state selection +- Added CPU, max-executor-memory and duration metadata in job tracker ### Changed ### Removed diff --git a/src/openeo_gfmap/manager/job_manager.py b/src/openeo_gfmap/manager/job_manager.py index b5c20d8..9a9f7b2 100644 --- a/src/openeo_gfmap/manager/job_manager.py +++ b/src/openeo_gfmap/manager/job_manager.py @@ -211,6 +211,17 @@ def _update_statuses(self, df: pd.DataFrame): future.add_done_callback(partial(done_callback, df=df, idx=idx)) self._futures.append(future) df.loc[idx, "costs"] = job_metadata["costs"] + df.loc[idx, "memory"] = ( + job_metadata["usage"] + .get("max_executor_memory", {}) + .get("value", None) + ) + df.loc[idx, "cpu"] = ( + job_metadata["usage"].get("cpu", {}).get("value", None) + ) + df.loc[idx, "duration"] = ( + job_metadata["usage"].get("duration", {}).get("value", None) + ) # Case in which it failed if (df.loc[idx, "status"] != "error") and (