def METHOD_NAME(setup_cluster):
    def f(*_):
        class Unpickleable:
            def __reduce__(self):
                raise ValueError
        raise KeyError(Unpickleable())
    with pytest.raises(mo.SendMessageFailed):
        d = spawn(f, retry_when_fail=False)
        d.execute()