

def _check_commands(self):
    if (not self._shutdown):
        self.logger.debug('Checking commands')
        command = self.resq.redis.lpop(('resque:khan:%s' % str(self)))
        self.logger.debug(('COMMAND FOUND: %s ' % command))
        if command:
            self.process_command(command)
            self._check_commands()

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