replace multiprocessing by multiprocess which uses dill as pickler, t…

…his fixes #2
usc-isi-i2 · May 6, 2020 · 669d302 · 669d302
1 parent 54e3e6c
commit 669d302
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/pyrallel/map_reduce.py b/pyrallel/map_reduce.py
@@ -37,8 +37,8 @@ def reducer(r1, r2):
 """
 __all__ = ['MapReduce']
 
-import multiprocessing as mp
-import multiprocessing.queues as mpq
+import multiprocess as mp
+import multiprocess.queues as mpq
 import queue
 from typing import Callable
 import sys

diff --git a/pyrallel/parallel_processor.py b/pyrallel/parallel_processor.py
@@ -85,7 +85,7 @@ def collector(data):
     print(processed)
 """
 
-import multiprocessing as mp
+import multiprocess as mp
 import threading
 import queue
 import inspect

diff --git a/requirements.txt b/requirements.txt
@@ -1 +1,2 @@
 typing>=3.6
+multiprocess>=0.70