

def get(self, timeout=1):
    try:
        msg = self.queue.get(timeout=timeout)
        if (msg.type == Message.NACK):
            raise Nack(self.request)
        elif (msg.type == Message.ERROR):
            raise RemoteError.from_reply(timeout.request, msg)
        return msg
    except gevent.queue.Empty:
        raise Timeout(self.request)
    finally:
        self.close()

dataset/ETHPy150Open deliveryhero/lymph/lymph/core/channels.py RequestChannel.get/VarMisuse@71/79 `self`->`timeout`