diff --git a/loky/backend/reduction.py b/loky/backend/reduction.py index 0d40c5ef..0bad5f63 100644 --- a/loky/backend/reduction.py +++ b/loky/backend/reduction.py @@ -188,7 +188,11 @@ def __init__(self, writer, reducers=None, protocol=HIGHEST_PROTOCOL): if sys.version_info < (3,): self.dispatch = self._dispatch.copy() else: - self.dispatch_table = self._dispatch_table.copy() + if getattr(self, "dispatch_table", None) is not None: + self.dispatch_table.update(self._dispatch_table.copy()) + else: + self.dispatch_table = self._dispatch_table.copy() + for type, reduce_func in reducers.items(): self.register(type, reduce_func)