async def query(self, query: str, *args, **kwargs) -> datatypes.Set:
    (await self._ensure_transaction())
    con = self._connection_inner
    (result, _) = (await self._connection_impl._protocol.execute_anonymous(query=query, args=args, kwargs=kwargs, reg=con._codecs_registry, qc=con._query_cache, io_format=protocol.IoFormat.BINARY))
    return result
async def query(self, query: str, *args, **kwargs) -> datatypes.Set:
    (await self._ensure_transaction())
    con = self._connection_inner
    (result, _) = (await self._connection_impl._protocol.execute_anonymous(query=query, args=args, kwargs=kwargs, reg=con._codecs_registry, qc=con._query_cache, io_format=protocol.IoFormat.BINARY))
    return result