Skip to content
Snippets Groups Projects
Commit fc6625d2 authored by Felix Kleinert's avatar Felix Kleinert
Browse files

remove dask from defaultdh

parent eec379fc
No related branches found
No related tags found
6 merge requests!319add all changes of dev into release v1.4.0 branch,!318Resolve "release v1.4.0",!283Merge latest develop into falcos issue,!264Merge develop into felix_issue287_tech-wrf-datahandler-should-inherit-from-singlestationdatahandler,!263Resolve "DefaultDataHandler: dask.compute() before dump to file",!259Draft: Resolve "WRF-Datahandler should inherit from SingleStationDatahandler"
Pipeline #61999 passed with warnings
Stage: test
Stage: docs
Stage: pages
Stage: deploy
This commit is part of merge request !318. Comments created here will be created in the context of that merge request.
Show whitespace changes
Inline Side-by-side
mlair/data_handler/default_data_handler.py
+ 1
− 1
View file @ fc6625d2
...@@ -85,7 +85,7 @@ class DefaultDataHandler(AbstractDataHandler): ...@@ -85,7 +85,7 @@ class DefaultDataHandler(AbstractDataHandler):
self._cleanup() if fresh_store is True else None self._cleanup() if fresh_store is True else None
data = {"X": self._X, "Y": self._Y, "X_extreme": self._X_extreme, "Y_extreme": self._Y_extreme} data = {"X": self._X, "Y": self._Y, "X_extreme": self._X_extreme, "Y_extreme": self._Y_extreme}
with open(self._save_file, "wb") as f: with open(self._save_file, "wb") as f:
pickle.dump(dask.compute(data), f) pickle.dump(data, f)
logging.debug(f"save pickle data to {self._save_file}") logging.debug(f"save pickle data to {self._save_file}")
self._reset_data() self._reset_data()
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment