diff --git a/openeogeotrellis/geopysparkcubemetadata.py b/openeogeotrellis/geopysparkcubemetadata.py
index e8b8148a..75378a1a 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 0f2f410a..3e6225be 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,