check_msg_error

def check_msg_error(msg: Message | None) -> Message | None:
    """Checks for errors in the consumed message."""
    if msg is None or msg.error():
        return None

    return msg