code: def _execute(self, endpoint, database, query, default_timeout, properties=None):
          
  
          request_payload = {"db": database, "csl": query}
          if properties:
              request_payload["properties"] = properties.to_json()
  
          request_headers = {
              "Accept": "application/json",
              "Accept-Encoding": "gzip,deflate",
              "Content-Type": "application/json; charset=utf-8",
              "x-ms-client-version": "Kusto.Python.Client:" + VERSION,
              "x-ms-client-request-id": "KPC.execute;" + str(uuid.uuid4()),
          }
  
          if self._auth_provider:
              request_headers["Authorization"] = self._auth_provider.acquire_authorization_header()
  
          timeout = self._get_timeout(properties, default_timeout)
          response = self._session.post(endpoint, headers=request_headers, json=request_payload, timeout=timeout.seconds)
  
          if response.status_code == 200:
              if endpoint.endswith("v2/rest/query"):
                  return KustoResponseDataSetV2(response.json())
              return KustoResponseDataSetV1(response.json())
  
          raise KustoServiceError([response.json()], response)
docs: Executes given query against this client