def put(self, data, block=True):

        self.start(test_connection=False)
        while True:
            response = self._req_rep(QueuingServerMessageListener.SPACE)
            if response == QueuingServerMessageListener.SPACE_AVAILABLE:
                self._req_rep((QueuingServerMessageListener.DATA, data))
                break
            else:
                time.sleep(0.01)
Ray -- Parallel genome assemblies for parallel DNA sequencing
dataset/ETHPy150Open SmokinCaterpillar/pypet/pypet/utils/mpwrappers.py/QueuingClient.put--crossover with--dataset/ETHPy150Open chapmanb/cloudbiolinux/cloudbio/custom/bio_nextgen.py/install_ray