We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b2a2403 commit caab4afCopy full SHA for caab4af
src/coffea/processor/executor.py
@@ -514,7 +514,7 @@ def __init__(
514
):
515
if mp_context is None:
516
mp_context = multiprocessing.get_context()
517
- mp_context.reducer = cloudpickle.Pickler()
+ mp_context.reduction.ForkingPickler = cloudpickle.Pickler
518
super().__init__(
519
max_workers=max_workers,
520
mp_context=mp_context,
0 commit comments