async def send_to_event_stream(self, connection_id: str, data: dict):
        """Send data to an event stream."""
Send data to an event stream.
openhands/server/conversation_manager/conversation_manager.py