diff --git a/parmap.py b/parmap.py index 63d77f0e67a9b9af7f32365f6c6a96be9394e20a..5107c09ae3c0644079e0aefd56c747948499d9e6 100644 --- a/parmap.py +++ b/parmap.py @@ -43,11 +43,11 @@ def worker_fun(f, q_in, q_out, multimap, chunksize): def parmap(f, X, nprocs = None, chunksize = 1, chunks_in_flight = None, - inOrder = True, multimap = False, out_chunksize = None): + in_order = True, multimap = False, out_chunksize = None): if nprocs is None: nprocs = multiprocessing.cpu_count() - if inOrder: + if in_order: out_chunksize = None if out_chunksize is not None: @@ -87,7 +87,7 @@ def parmap(f, X, nprocs = None, chunksize = 1, chunks_in_flight = None, running_workers -= 1 continue - if not inOrder: + if not in_order: if out_chunksize is None: cont.release() if val is None: