diff --git a/aggregator.py b/aggregator.py index 549a0d5..92b5746 100644 --- a/aggregator.py +++ b/aggregator.py @@ -47,7 +47,7 @@ class Aggregator: _map_aux, func, self.path, self.path_out, self.pp_params, **kwargs ) - pool = MyPool(processes=num_process) + pool = MyPool(processes=num_process, maxtasksperchild=1) result = pool.map(map_fn, run_num) pool.close() pool.join()