async def ensure_client_readiness(self) -> None:
        """Ensure the client is ready to accept requests."""
        if self.client is None:
            await self.connect_to_qdrant()
            if self.client is None:
                raise ConnectionError(
                    "Failed to establish connection to Qdrant service. Please check if "
                    "the service is running and accessible."
                )
Ensure the client is ready to accept requests.
backend/airweave/platform/destinations/qdrant.py