From 2b6750daab7936c976d9f98e8d258ce4de86f4b0 Mon Sep 17 00:00:00 2001 From: Emma Ai Date: Fri, 27 Oct 2023 11:01:30 +1030 Subject: [PATCH] remove early dask unpack (#101) Co-authored-by: emmaai --- odc/stats/proc.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/odc/stats/proc.py b/odc/stats/proc.py index 30e59f2e..d57536a8 100644 --- a/odc/stats/proc.py +++ b/odc/stats/proc.py @@ -229,7 +229,7 @@ def _run(self, tasks: Iterable[Task], apply_eodatasets3) -> Iterator[TaskResult] ) _log.debug("Submitting to Dask (%s)", task.location) - ds = client.persist(ds, fifo_timeout="1ms") + # ds = client.persist(ds, fifo_timeout="1ms") aux: Optional[xr.Dataset] = None