Issue #149 Add processes_target_version config

Author: soxofaan

CHANGELOG.md

@@ -8,6 +8,8 @@ The format is roughly based on [Keep a Changelog](https://keepachangelog.com/en/
 
 ## Work in progress: 0.46.0
 
+- Add `AggregatorBackendConfig.processes_target_version` to define processes target version ([#149](https://github.com/Open-EO/openeo-aggregator/issues/149))
+
 
 ## 0.45.0
 

src/openeo_aggregator/backend.py

@@ -497,9 +497,8 @@ def to_response_dict(self) -> dict:
 class AggregatorProcessRegistry(ProcessRegistry):
     """ProcessRegistry with a bit of aggregator-specific customization"""
 
-    def __init__(self, federation_missing: Iterable[str] = ()):
-        # TODO #149 target_version=...
-        super().__init__()
+    def __init__(self, federation_missing: Iterable[str] = (), target_version: Optional[str] = None):
+        super().__init__(target_version=target_version)
         self._federation_missing = list(federation_missing)
 
     def get_processes_listing(self, *, exclusion_list: Optional[Iterable[str]] = None) -> ProcessesListing:
@@ -529,7 +528,8 @@ def get_process_registry(self, api_version: Union[str, ComparableVersion]) -> Pr
 
         processes_metadata = self.get_merged_process_metadata()
         process_registry = AggregatorProcessRegistry(
-            federation_missing=processes_metadata.get("federation:missing", [])
+            federation_missing=processes_metadata.get("federation:missing", []),
+            target_version=get_backend_config().processes_target_version,
         )
         for pid, spec in processes_metadata["combined_processes"].items():
             process_registry.add_spec(spec=spec)

src/openeo_aggregator/config/config.py

@@ -54,6 +54,8 @@ class AggregatorBackendConfig(OpenEoBackendConfig):
         packages=["openeo", "openeo_driver", "openeo_aggregator"],
     )
 
+    processes_target_version: Optional[str] = None
+
     # TODO: allow to specify more info per backend in addtion to just URL: title, description, experimental flag, ...
     aggregator_backends: Dict[str, str] = attrs.field(validator=attrs.validators.min_len(1))
 

tests/backend_config.py

@@ -17,6 +17,7 @@
         "b1": "https://b1.test/v1",
         "b2": "https://b2.test/v1",
     },
+    processes_target_version="1.2.0",
     connections_cache_ttl=1.0,
     zookeeper_prefix="/o-a/",
     memoizer={

tests/test_views.py

@@ -771,7 +771,7 @@ def test_processes_basic(self, api100, requests_mock, backend1, backend2):
                 },
             ],
             "links": [],
-            "version": None,
+            "version": "1.2.0",
             "federation:missing": [],
         }
 
@@ -901,7 +901,7 @@ def test_processes_resilience(
         assert res == {
             "processes": expected,
             "links": [],
-            "version": None,
+            "version": "1.2.0",
             "federation:missing": federation_missing,
         }
 
@@ -1065,7 +1065,7 @@ def test_processes_different_versions(self, api100, requests_mock, backend1, bac
                 DictSubSet({"id": "prod", "federation:backends": ["b2"]}),
             ],
             "links": [],
-            "version": None,
+            "version": "1.2.0",
             "federation:missing": [],
         }