'Makes a RunQuery call that will modify the instance.
Args:
config: The datastore_rpc.Configuration to use for the call.
req: The request to send with the call.
Returns:
A UserRPC object that can be used to fetch the result of the RPC.'

def _make_query_rpc_call(self, config, req):

    _api_version = self._batch_shared.conn._api_version
    if (_api_version == datastore_rpc._CLOUD_DATASTORE_V1):
        return self._batch_shared.conn._make_rpc_call(config, 'RunQuery', req, googledatastore.RunQueryResponse(), self.__v1_run_query_response_hook)
    return self._batch_shared.conn._make_rpc_call(config, 'RunQuery', req, datastore_pb.QueryResult(), self.__query_result_hook)
