diff options
| author |  Jonas Gunz <himself@jonasgunz.de>
| 2024-10-21 00:42:26 +0200 |
|---|---|---|
| committer | Jonas Gunz <himself@jonasgunz.de>
| 2024-10-21 00:42:26 +0200 |
| commit | 381a8c282eccb9f448c1ff5392329087e2b3c448 (patch) | |
| tree | 1c14abf1995d0c390e0c81fe04afb1d78e3f00be /metchart | |
| parent | f809e0dd326c1120ec28500f72a085a25acc5520 (diff) | |
| download | meteo_toolbox-381a8c282eccb9f448c1ff5392329087e2b3c448.tar.gz | |
remove multiprocessing
Diffstat (limited to 'metchart')
| -rw-r--r-- | metchart/manager.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/metchart/manager.py b/metchart/manager.py index a49b75e..b7723d3 100644 --- a/metchart/manager.py +++ b/metchart/manager.py @@ -7,7 +7,6 @@ import os import importlib from multiprocessing import cpu_count -from multiprocessing.pool import ThreadPool def run_if_present(key, dct: dict, func: Callable, *args, **kwargs): @@ -28,7 +27,7 @@ class Manager: self._parse() def run_plotters(self): - index = ThreadPool(self._thread_count).map(lambda p: p['module'].run(**p['cfg']), self._plotters) + index = map(lambda p: p['module'].run(**p['cfg']), self._plotters) with open(os.path.join(self._output_dir, 'index.json'), 'w') as f: # NOTE index needs to be flattened. |