async def execute(self, query, *,
                      dc=None, near=None, limit=None, consistency=None):
        query_id = extract_attr(query, keys=["ID"])
        response = await self._api.get(
            "/v1/query/%s/execute" % query_id,
            params={"dc": dc, "near": near, "limit": limit},
            consistency=consistency)
        return response.body