code: async def _query_validator(self, request_type, response_proto,
                                 payload, error_traps=None):
          
          LOGGER.debug(
              'Sending %s request to validator',
              self._get_type_name(request_type))
  
          payload_bytes = payload.SerializeToString()
          response = await self._send_request(request_type, payload_bytes)
          content = self._parse_response(response_proto, response)
  
          LOGGER.debug(
              'Received %s response from validator with status %s',
              self._get_type_name(response.message_type),
              self._get_status_name(response_proto, content.status))
  
          self._check_status_errors(response_proto, content, error_traps)
          return self._message_to_dict(content)
docs: Sends a request to the validator and parses the response.