async def _maybe_handle_evt_retrieve_conversation_item_error(self, evt: events.ErrorEvent):
        """If the given error event is an error retrieving a conversation item:
        - set an exception on the future that retrieve_conversation_item() is waiting on
        - return true
        Otherwise:
        - return false
        """
        if evt.error.code == "item_retrieve_invalid_item_id":
            item_id = evt.error.event_id.split("_", 1)[1]  # event_id is of the form "rci_{item_id}"
            futures = self._retrieve_conversation_item_futures.pop(item_id, None)
            if futures:
                for future in futures:
                    future.set_exception(Exception(evt.error.message))
            return True
        return False
If the given error event is an error retrieving a conversation item:
        - set an exception on the future that retrieve_conversation_item() is waiting on
        - return true
        Otherwise:
        - return false
        
src/pipecat/services/openai_realtime_beta/openai.py