def requestjob(self):
        if self.model is None:
            raise RuntimeError("worker must be initialized before receiving jobs")

        job = None
        while job is None and not self.finished:
            try:
                job = self.dispatcher.getjob(self.myid)
            except Queue.Empty:
                # no new job: try again, unless we're finished with all work
                continue
        if job is not None:
            logger.info("worker #%s received job #%i" % (self.myid, self.jobsdone))
            self.processjob(job)
            self.dispatcher.jobdone(self.myid)
        else:
            logger.info("worker #%i stopping asking for jobs" % self.myid)
Verifies the client's command is valid and allowed.
dataset/ETHPy150Open largelymfs/topical_word_embeddings/TWE-1/gensim/models/lsi_worker.py/Worker.requestjob--crossover with--dataset/ETHPy150Open google/lab_device_proxy/lab_device_proxy_server.py/LabDeviceProxyRequestHandler._ValidateCommand