def __init__(self, socket, varz_tag):
    self._socket = socket
    self._is_open = self._socket.isOpen()
    self._varz = self.Varz(Source(service=varz_tag, endpoint='%s:%d' % (self.host, self.port)))
dataset/ETHPy150Open steveniemitz/scales/scales/varz.py/VarzSocketWrapper.__init__/original