Fix for #266

pathos multiprocessing imap was resulting in broke spotpy database. Switching to map solces the issue
thouska · May 31, 2021 · 80435f9 · 80435f9
1 parent 6be2dcf
commit 80435f9
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 4 deletions.
diff --git a/spotpy/examples/spot_setup_hymod_exe.py b/spotpy/examples/spot_setup_hymod_exe.py
@@ -11,7 +11,6 @@
 import numpy as np
 import spotpy
 import os
-import multiprocessing as mp
 from distutils.dir_util import copy_tree, remove_tree
 #from shutil import rmtree
 import sys

diff --git a/spotpy/examples/tutorial_parallel_computing_hymod.py b/spotpy/examples/tutorial_parallel_computing_hymod.py
@@ -47,7 +47,7 @@
     sampler.sample(rep)
 
     # Load results from file
-    #results = spotpy.analyser.load_csv_results('Parallel_hymod')
-
+    results = spotpy.analyser.load_csv_results('Parallel_hymod')
+    print(len(results))
     # Plot best model run
     #spotpy.analyser.plot_bestmodelrun(results,spot_setup.evaluation())
diff --git a/spotpy/parallel/mproc.py b/spotpy/parallel/mproc.py
@@ -50,6 +50,6 @@ def f(self, job):
         return data
 
     def __call__(self, jobs):
-        results = self.pool.imap(self.f, jobs)
+        results = self.pool.map(self.f, jobs)
         for i in results:
             yield i