From faaa3388db7ba50ab7627de6537d4c23efad7e6d Mon Sep 17 00:00:00 2001
From: leufen1 <l.leufen@fz-juelich.de>
Date: Tue, 16 Mar 2021 17:39:00 +0100
Subject: [PATCH] single compute call was missing
---
mlair/data_handler/data_handler_mixed_sampling.py | 2 +-
mlair/helpers/statistics.py | 3 ++-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/mlair/data_handler/data_handler_mixed_sampling.py b/mlair/data_handler/data_handler_mixed_sampling.py
index c56499dc..c62e18f2 100644
--- a/mlair/data_handler/data_handler_mixed_sampling.py
+++ b/mlair/data_handler/data_handler_mixed_sampling.py
@@ -218,7 +218,7 @@ class DataHandlerSeparationOfScalesSingleStation(DataHandlerMixedSamplingWithFil
res_filter.append(data_filter.shift({dim: -w * delta}))
res_filter = xr.concat(res_filter, dim=window_array).chunk()
res.append(res_filter)
- res = xr.concat(res, dim="filter")
+ res = xr.concat(res, dim="filter").compute()
return res
def estimate_filter_width(self):
diff --git a/mlair/helpers/statistics.py b/mlair/helpers/statistics.py
index 0b73bc27..a8ba9795 100644
--- a/mlair/helpers/statistics.py
+++ b/mlair/helpers/statistics.py
@@ -669,8 +669,9 @@ class KolmogorovZurbenkoFilterMovingWindow(KolmogorovZurbenkoBaseClass):
self.filter_dim: wl}
iter_vars = df_itr.coords["variables"].values
for var in iter_vars:
- df_itr_var = df_itr.sel(variables=[var]).chunk()
+ df_itr_var = df_itr.sel(variables=[var])
for _ in np.arange(0, itr):
+ df_itr_var = df_itr_var.chunk()
rolling = df_itr_var.rolling(**kwargs)
if self.method == "median":
df_mv_avg_tmp = rolling.median()
--
GitLab