async def _post(self, client: httpx.AsyncClient, path: str, json_body: Dict[str, Any]) -> Any:
        """Make an authenticated POST request to the Elasticsearch API."""
        headers = (
            {
                "Authorization": f"ApiKey {self.api_key}",
                "Content-Type": "application/json",
            }
            if self.api_key
            else {"Content-Type": "application/json"}
        )
        response = await client.post(path, json=json_body, headers=headers)
        response.raise_for_status()
        return response.json()
Make an authenticated POST request to the Elasticsearch API.
backend/airweave/platform/sources/elasticsearch.py