fix query

CMCC-Foundation · Jun 27, 2024 · 7783589 · 7783589
1 parent 0c5bbe9
commit 7783589
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/datastore/datastore/datastore.py b/datastore/datastore/datastore.py
@@ -358,9 +358,9 @@ def query(
         self._LOG.debug("loading product...")
         kube = self.catalog(CACHE_DIR=self.cache_dir)[dataset_id][
             product_id
-        ].get(geoquery=geoquery, compute=compute).process_with_query()
+        ].read_chunked()
         self._LOG.debug("original kube len: %s", len(kube))
-        return kube
+        return Datastore._process_query(kube, geoquery, compute)
 
     @log_execution_time(_LOG)
     def estimate(