From 491237f7f0f7cb9916f280ad5e71bc9eb1046813 Mon Sep 17 00:00:00 2001 From: emile Date: Fri, 17 May 2024 00:25:53 +0200 Subject: [PATCH] Read parallel_query. https://github.com/eu-cdse/openeo-cdse-infra/issues/107 --- openeogeotrellis/geopysparkcubemetadata.py | 3 +++ openeogeotrellis/layercatalog.py | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/openeogeotrellis/geopysparkcubemetadata.py b/openeogeotrellis/geopysparkcubemetadata.py index e8b8148a1..75378a1ac 100644 --- a/openeogeotrellis/geopysparkcubemetadata.py +++ b/openeogeotrellis/geopysparkcubemetadata.py @@ -85,6 +85,9 @@ def provider_backend(self) -> Union[str, None]: def auto_polarization(self) -> Union[str, None]: return self.get("_vito", "data_source", "auto_polarization", default=False) + def parallel_query(self) -> Union[str, None]: + return self.get("_vito", "data_source", "parallel_query", default=False) + def common_name_priority(self) -> int: priority = self.get("_vito", "data_source", "common_name_priority", default=None) if priority is not None: diff --git a/openeogeotrellis/layercatalog.py b/openeogeotrellis/layercatalog.py index 0f2f410aa..3e6225be8 100644 --- a/openeogeotrellis/layercatalog.py +++ b/openeogeotrellis/layercatalog.py @@ -337,7 +337,7 @@ def pyramid_factory( root_path, ): opensearch_client = jvm.org.openeo.opensearch.OpenSearchClient.apply( - opensearch_endpoint, is_utm, "", metadata.band_names, catalog_type + opensearch_endpoint, is_utm, "", metadata.band_names, catalog_type, metadata.parallel_query() ) return jvm.org.openeo.geotrellis.file.PyramidFactory( opensearch_client,