@classmethod
def sync_processes(cls, *args, **kwargs):
    """
        Make sure processes are all at the same point by calling the `.sync_processes()` implementation in the
        multiprocessing engine

        This is necessary for KVS; other engines will just return True
        """
    if not cls.is_initialized:
        raise RuntimeError('Connect before calling sync_processes()')
    return cls.client.sync_processes(*args, **kwargs)
