VP reproject: do not propagate dask_chunks leafwards

opendatacube · Sep 24, 2019 · 33480b0 · 33480b0
1 parent e84a8bf
commit 33480b0
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/datacube/virtual/impl.py b/datacube/virtual/impl.py
@@ -776,9 +776,7 @@ def fetch(self, grouped: VirtualDatasetBox, **load_settings: Dict[str, Any]) ->
         if dask_chunks is None:
             rasters = [self._input.fetch(box, **load_settings) for box in boxes]
         else:
-            self._assert('input_dask_chunks' in self, "no input_dask_chunks specified in reproject")
-
-            rasters = [self._input.fetch(box, dask_chunks=self['input_dask_chunks'],
+            rasters = [self._input.fetch(box, dask_chunks={key: 1 for key in dask_chunks if key not in geobox.dims},
                                          **reject_keys(load_settings, ['dask_chunks']))
                        for box in boxes]