def _handle_topology_change(self, event):
        change_type = event["change_type"]
        addr = self._translate_address(event["address"][0])
        if change_type == "NEW_NODE" or change_type == "MOVED_NODE":
            if self._topology_event_refresh_window >= 0:
                delay = self._delay_for_event_type('topology_change', self._topology_event_refresh_window)
                self._cluster.scheduler.schedule_unique(delay, self.refresh_node_list_and_token_map)
        elif change_type == "REMOVED_NODE":
            host = self._cluster.metadata.get_host(addr)
            self._cluster.scheduler.schedule_unique(0, self._cluster.remove_host, host)
dataset/ETHPy150Open datastax/python-driver/cassandra/cluster.py/ControlConnection._handle_topology_change/original