async def _monitor_websocket(self):
        """Wait for self._params.session_timeout seconds, if the websocket is still open, trigger timeout event."""
        await asyncio.sleep(self._params.session_timeout)
        await self._client.trigger_client_timeout()
Wait for self._params.session_timeout seconds, if the websocket is still open, trigger timeout event.
src/pipecat/transports/network/fastapi_websocket.py