Renaming

Author: w8jcik

src/moldrug/runner.py

@@ -17,7 +17,7 @@ def serial_execution(func: Callable, entries: List):
     return [func(args) for args in tqdm.tqdm(entries, total=len(entries))]
 
 
-def parallel_execution_processes(func: Callable, entries: List, process_count: int):
+def parallel_execution_multiprocessing(func: Callable, entries: List, process_count: int):
     pool = mp.Pool(process_count)
     results = [entry for entry in tqdm.tqdm(pool.imap(func, entries), total=len(entries))]
     pool.close()
@@ -75,7 +75,7 @@ def run(self, func: Callable, entries: List):
         if self.mode == RunnerMode.SERIAL:
             return serial_execution(func, entries)
         elif self.mode == RunnerMode.PROCESSES:
-            return parallel_execution_processes(func, entries, process_count=self.process_count)
+            return parallel_execution_multiprocessing(func, entries, process_count=self.process_count)
         elif self.mode == RunnerMode.DASK_LOCAL:
             return parallel_execution_dask_local(func, entries, process_count=self.process_count, process_threads_count=self.thread_count)
         if self.mode == RunnerMode.DASK_JOB_QUEUE_CLUSTER:

src/moldrug/utils.py

@@ -24,7 +24,7 @@
 from rdkit.Chem import AllChem, DataStructs, Descriptors, Lipinski, rdFMCS
 
 from moldrug import __version__
-from moldrug.runner import Runner, RunnerMode, parallel_execution_processes
+from moldrug.runner import Runner, RunnerMode, parallel_execution_multiprocessing
 
 RDLogger.DisableLog('rdApp.*')
 # # in order to pickle the isotope properties of the molecule
@@ -1163,7 +1163,7 @@ def __call__(self, njobs: int = 1, pick: int = None):
             args_list.append((individual, kwargs_copy))
 
         print('Calculating cost function...')
-        self.pop = parallel_execution_processes(self.__costfunc__, args_list, njobs)
+        self.pop = parallel_execution_multiprocessing(self.__costfunc__, args_list, njobs)
 
         # Clean directory
         costfunc_jobs_tmp_dir.cleanup()