fork subprocess and set neuron dt before ipyp process

Author: Jaquier Aurélien Tristan

bluepyopt/deapext/optimisations.py

@@ -199,7 +199,10 @@ def setup_deap(self):
 
         # Register the evaluation function for the individuals
         # import deap_efel_eval1
-        self.toolbox.register("evaluate", self.evaluator.evaluate_with_lists)
+        self.toolbox.register(
+            "evaluate",
+            self.evaluator.set_neuron_variables_and_evaluate_with_lists
+        )
 
         # Register the mate operator
         self.toolbox.register(

bluepyopt/ephys/evaluators.py

@@ -216,6 +216,17 @@ def evaluate_with_lists(self, param_list=None, target='scores'):
 
         return self.objective_list(obj_dict)
 
+    def set_neuron_variables_and_evaluate_with_lists(
+        self, param_list=None, target='scores'
+    ):
+        """Set neuron variables and run evaluation with lists.
+        
+        Setting the neuron variables is necessary when using ipyparallel,
+        since the new subprocesses have pristine neuron.
+        """
+        # self.sim.set_neuron_variables()
+        return self.evaluate_with_lists(param_list=param_list, target=target)
+
     def evaluate(self, param_list=None, target='scores'):
         """Run evaluation with lists as input and outputs"""
 

bluepyopt/ephys/protocols.py

@@ -245,12 +245,20 @@ def _reduce_method(meth):
             copyreg.pickle(types.MethodType, _reduce_method)
             import pebble
             from concurrent.futures import TimeoutError
+            import multiprocessing
+
+            # Default context for python>=3.8 on macos is spawn.
+            # Spwan context would reset neuron properties, such as dt.
+            multiprocessing_context = multiprocessing.get_context('fork')
 
             if timeout is not None:
                 if timeout < 0:
                     raise ValueError("timeout should be > 0")
-
-            with pebble.ProcessPool(max_workers=1, max_tasks=1) as pool:
+            with pebble.ProcessPool(
+                max_workers=1,
+                max_tasks=1,
+                context=multiprocessing_context
+            ) as pool:
                 tasks = pool.schedule(self._run_func, kwargs={
                     'cell_model': cell_model,
                     'param_values': param_values,

bluepyopt/ephys/simulators.py

@@ -40,16 +40,15 @@ def __init__(self, dt=None, cvode_active=True, cvode_minstep=None,
         self.disable_banner = platform.system() not in ['Windows', 'Darwin']
         self.banner_disabled = False
         self.mechanisms_directory = mechanisms_directory
-        self.neuron.h.load_file('stdrun.hoc')
 
         self.dt = dt if dt is not None else self.neuron.h.dt
-        self.neuron.h.dt = self.dt
 
-        self.neuron.h.cvode_active(1 if cvode_active else 0)
         self.cvode_minstep_value = cvode_minstep
 
         self.cvode_active = cvode_active
 
+        self.set_neuron_variables()
+
         self.random123_globalindex = random123_globalindex
 
     @property
@@ -105,6 +104,12 @@ def neuron(self):
 
         return neuron
 
+    def set_neuron_variables(self):
+        """Set neuron variables"""
+        self.neuron.h.load_file('stdrun.hoc')
+        self.neuron.h.dt = self.dt
+        self.neuron.h.cvode_active(1 if self.cvode_active else 0)
+
     def run(
             self,
             tstop=None,