import multiprocessing
import multiprocessing.util


class EvilPayload(object):
    def __init__(self):
        pass

    def __reduce_ex__(self, proto):
        return EvilPayload, (1, 2, 3)


def return_evil_payload(n):
    return EvilPayload()


def test_multiprocessing_with_unpicklable():
    multiprocessing.util.log_to_stderr(10)

    with multiprocessing.Pool(1) as p: 
        evil = p.map_async(return_evil_payload, [1]).get(timeout=2)


if __name__ == "__main__":
    test_multiprocessing_with_unpicklable()
    print("PASS")