def get(self, queue):
        if not queue:
            raise Empty
        if queue not in self.client.watching():
            self.client.watch(queue)

        ignore = ifilter(lambda q: q!= queue, self.client.watching())
        map(self.client.ignore, ignore)

        job = self.client.reserve(timeout=1)
        item, dest = self._parse_job(job)
        return item
dataset/ETHPy150Open ask/ghettoq/ghettoq/backends/beanstalk.py/BeanstalkBackend.get/original