async def _get(
        self,
        client: httpx.AsyncClient,
        path: str,
        params: Optional[Dict[str, Any]] = None,
    ) -> Any:
        """Make an authenticated GET request to the Elasticsearch API."""
        headers = {"Authorization": f"ApiKey {self.api_key}"} if self.api_key else {}
        response = await client.get(path, params=params, headers=headers)
        response.raise_for_status()
        return response.json()
Make an authenticated GET request to the Elasticsearch API.
backend/airweave/platform/sources/elasticsearch.py