diff --git a/great_ai/utilities/parallel_map/parallel_map.py b/great_ai/utilities/parallel_map/parallel_map.py index 0c088c0..e95604d 100644 --- a/great_ai/utilities/parallel_map/parallel_map.py +++ b/great_ai/utilities/parallel_map/parallel_map.py @@ -99,7 +99,7 @@ def parallel_map( output_queue = manager.Queue(config.concurrency * 2) should_stop = ctx.Event() - serialized_map_function = dill.dumps(function, byref=True, recurse=True) + serialized_map_function = dill.dumps(function, byref=True, recurse=False) processes = [ ctx.Process(