Added dask process option

Signed-off-by: Suhail Rehman <suhailrehman@gmail.com>
suhailrehman · Jun 21, 2022 · af92295 · af92295
1 parent 600cd44
commit af92295
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/fuzzydata/clients/modin.py b/fuzzydata/clients/modin.py
@@ -29,7 +29,8 @@ def __init__(self, *args, **kwargs):
 
         if self.modin_engine == 'dask':
             from dask.distributed import Client
-            Client()
+            processes = kwargs.pop('processes', False)
+            Client(processes=processes)
         else:
             import ray
             ray.init(ignore_reinit_error=True)

diff --git a/setup.py b/setup.py
@@ -5,7 +5,7 @@
 
 setup(
     name="fuzzydata",
-    version="0.0.4",
+    version="0.0.5",
     scripts=['./scripts/fuzzydata'],
     author="Suhail Rehman",
     author_email="suhailrehman@gmail.com",