diff --git a/swash/processing/sws_npz.py b/swash/processing/sws_npz.py index d17c493..4e9c4ae 100644 --- a/swash/processing/sws_npz.py +++ b/swash/processing/sws_npz.py @@ -1,7 +1,7 @@ import argparse import configparser import logging -from multiprocessing.pool import Pool +from multiprocessing.pool import ThreadPool import pathlib import numpy as np @@ -39,7 +39,7 @@ var = { } inp.mkdir(exist_ok=True) -with Pool() as pool: +with ThreadPool() as pool: log.info("Converting all data") pool.map( lambda x: np.save(