diff --git a/src/nwp_consumer/internal/service/consumer.py b/src/nwp_consumer/internal/service/consumer.py
index 2137f30e..940ee00d 100644
--- a/src/nwp_consumer/internal/service/consumer.py
+++ b/src/nwp_consumer/internal/service/consumer.py
@@ -121,11 +121,12 @@ def CreateLatestZarr(self) -> list[pathlib.Path]:
         # * Then cache the dataset as a zarr file and store it in the store
         bag: dask.bag.Bag = dask.bag.from_sequence(cachedPaths)
         log.info('Made dask bag')
-        latestDataset = (
-            bag.map(lambda tfp: self.fetcher.mapCachedRaw(p=tfp))
-            .fold(lambda ds1, ds2: _mergeDatasets([ds1, ds2]))
-            .compute()
-        )
+        latestDataset = bag.map(lambda tfp: self.fetcher.mapCachedRaw(p=tfp))
+        log.info('Doing fold')
+        latestDataset = latestDataset.fold(lambda ds1, ds2: _mergeDatasets([ds1, ds2]))
+        log.info('Doing compute')
+        latestDataset = latestDataset.compute()
+
         log.info('Made latest Dataset')
         if not _dataQualityFilter(ds=latestDataset):
             return []