def run(self):
        load_modules()
        self.lib = library

        while not self.stop_event.is_set():
            try:
                name, uuid, args, kwargs = self.queue_in.get(True)
                log.debug("greenqueue-worker{0}: received message from queue - {1}:{2}".format(self.name, name, uuid))
                self._process_task(name, uuid, args, kwargs)
            except __HOLE__:
                self.stop_event.set()
dataset/ETHPy150Open niwinz/django-greenqueue/greenqueue/worker/base.py/BaseWorker.run