

def work(self, interval=2):
    setproctitle('pyres_manager: Starting')
    self.startup()
    self.setup_minions()
    self._setup_logging()
    self.logger.info(('Running as pid: %s' % self.pid))
    self.logger.info(('Added %s child processes' % self.pool_size))
    self.logger.info('Setting up pyres connection')
    self.setup_resq()
    self.register_khan()
    setproctitle(('pyres_manager: running %s' % self.queues))
    while True:
        self._check_commands()
        if self._shutdown:
            self._shutdown_minions()
            break
        else:
            self.logger.debug(('manager sleeping for: %d secs' % interval))
            time.sleep(interval)
    self.unregister_khan()

dataset/ETHPy150Open binarydud/pyres/pyres/horde.py Khan.work/original