Fix incorrect progress callback in xr_load

Should not reset back to 1 for each ban
opendatacube · Apr 16, 2019 · acda70e · acda70e
1 parent 2353856
commit acda70e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/datacube/api/core.py b/datacube/api/core.py
@@ -496,14 +496,15 @@ def _cbk(*ignored):
             return _cbk
 
         data = Datacube.create_storage(sources.coords, geobox, measurements)
+        _cbk = mk_cbk(progress_cbk)
 
         for index, datasets in numpy.ndenumerate(sources.values):
             for m in measurements:
                 t_slice = data[m.name].values[index]
 
                 _fuse_measurement(t_slice, datasets, geobox, m,
                                   skip_broken_datasets=skip_broken_datasets,
-                                  progress_cbk=mk_cbk(progress_cbk))
+                                  progress_cbk=_cbk)
 
         return data