Changeset 800

Timestamp:

06/23/15 10:15:38 (11 months ago)

Author:

mmckerns

Message:

updated to use pathos.pools

Location:

branches/UQ/legacy

Files:

• MM_OUQ_StAlData.py (modified) (1 diff)
• envelope/Driver_BoLiSurr_Cy.py (modified) (1 diff)
• envelope/Looper_BoLiSurr_Cy.py (modified) (2 diffs)
• envelope/envelope.py (modified) (1 diff)

branches/UQ/legacy/MM_OUQ_StAlData.py

@@ -36 +36 @@
 #######################################################################
 def optimize(cost,_bounds,_constraints):
-  from pathos.multiprocessing import ProcessingPool as Pool
+  from pathos.pools import ProcessPool as Pool
   from mystic.solvers import DifferentialEvolutionSolver2
   from mystic.termination import ChangeOverGeneration as COG

branches/UQ/legacy/envelope/Driver_BoLiSurr_Cy.py

@@ -43 +43 @@
   # with multiprocessing 
 ##nodes = 7 #len(runs)
-##from pathos.multiprocessing import ProcessingPool as Pool
+##from pathos.pool import ProcessPool as Pool
 ##results = Pool(nodes).map(looper, runs)
   # with MPI

branches/UQ/legacy/envelope/Looper_BoLiSurr_Cy.py

@@ -76 +76 @@
   solver.SetConstraints(_constraints)
  #ALTERNATE: multiprocessing map of cost function
-##from pathos.multiprocessing import ProcessingPool as Pool
+##from pathos.pools import ProcessPool as Pool
 ##solver.SetMapper(Pool().map)
  #ALTERNATE: MPI map of cost function
@@ -384 +384 @@
   # with multiprocessing 
 ##nodes = 7 #len(runs)
-##from pathos.multiprocessing import ProcessingPool as Pool
+##from pathos.pools import ProcessPool as Pool
 ##results = Pool(nodes).map(looper, runs)
 

branches/UQ/legacy/envelope/envelope.py

@@ -236 +236 @@
   # with multiprocessing 
 # nodes = 4 #len(runs)
-# from pathos.multiprocessing import ProcessingPool as Pool
+# from pathos.pool import ProcessPool as Pool
 # results = Pool(nodes).map(model_sausage, runs)
   # with MPI