code: 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