Fix errors thrown by singleton during multiprocessing in python by passing as argument

singleton_multiprocessing_success_pass_arg.py

import time
from joblib import Parallel, delayed

class OnlyOne:
    """Singleton Class, inspired by 
    https://python-3-patterns-idioms-test.readthedocs.io/en/latest/Singleton.html"""
    class __OnlyOne:
        def __init__(self, arg):
            if arg is None:
                raise ValueError("Pretend empty instantiation breaks code")
            self.val = arg
        def __str__(self):
            return repr(self) + self.val
    instance = None
    def __init__(self, arg=None):
        if not self.instance:
            self.instance = self.__OnlyOne(arg)
        else:
            self.instance.val = arg
    def __getattr__(self, name):
        return getattr(self.instance, name)


def worker(num, one):
    """Single worker function to run in parallel.
    """
    time.sleep(0.1)
    one.val += num
    return one.val


# Instantiate singleton
one = OnlyOne(0)
print(one.val)

# Run in parallel succeeds when one is passed 
# as arg to worker
res = Parallel(n_jobs=-1, verbose=10)(
    delayed(worker)(i, one) for i in range(10)
)
print(res)