def _call(self, __name, **kwargs):
        channel = self._container.send_request(self._address, __name, kwargs, version=self._version)
        try:
            return channel.get(timeout=self._timeout).body
        except RemoteError as e:
            error_type = str(e.__class__)
            self.exception_counts.incr(name=e.__class__.__name__)
            if error_type in self._error_map:
                raise self._error_map[error_type]()
            raise
        except Timeout:
            self.timeout_counts += 1
            raise
        except Nack:
            self.exception_counts.incr(name='nack')
            raise
dataset/ETHPy150Open deliveryhero/lymph/lymph/core/interfaces.py/Proxy._call/original