Read parallel_query. eu-cdse/openeo-cdse-infra#107

Open-EO · May 16, 2024 · 491237f · 491237f
1 parent faffa90
commit 491237f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git 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
@@ -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,