def _get_websocket(self):
        """Get active websocket connection or raise exception."""
        if self._websocket:
            return self._websocket
        raise Exception("Websocket not connected")
Get active websocket connection or raise exception.
src/pipecat/services/rime/tts.py