diff --git a/cassandra/cluster.py b/cassandra/cluster.py index 501e5d1e..10075132 100644 --- a/cassandra/cluster.py +++ b/cassandra/cluster.py @@ -2949,14 +2949,13 @@ class ControlConnection(object): if local_row.get("schema_version"): versions[local_row.get("schema_version")].add(local_address) - pm = self._cluster.profile_manager for row in peers_result: schema_ver = row.get('schema_version') if not schema_ver: continue addr = self._rpc_from_peer_row(row) peer = self._cluster.metadata.get_host(addr) - if peer and peer.is_up and pm.distance(peer) != HostDistance.IGNORED: + if peer and peer.is_up is not False: versions[schema_ver].add(addr) if len(versions) == 1: