def _OnPingResponse(self, msg_type, stream):
    ar, self._ping_ar = self._ping_ar, None
    if msg_type == MessageType.Rping:
      ar.set()
      ping_duration = time.time() - self._last_ping_start
      self._log.debug('Got ping response in %d ms' % int(ping_duration * 1000))
    else:
      self._log.error('Unexpected response for tag 1 (msg_type was %d)' % msg_type)
      ar.set_exception(Exception("Invalid ping response"))
Clear all gauged data
dataset/ETHPy150Open steveniemitz/scales/scales/thriftmux/sink.py/SocketTransportSink._OnPingResponse--crossover with--dataset/ETHPy150Open chriso/gauged/gauged/drivers/mysql.py/MySQLDriver.clear_schema