Merge pull request apache#218 from datastax/PYTHON-163

aholmberg · aholmberg · commit b0897414d2c9 · 2014-12-03T19:01:19.000-06:00
PYTHON-163 - Don't try to connect to peers with incomplete meta
diff --git a/cassandra/cluster.py b/cassandra/cluster.py
@@ -2061,6 +2061,11 @@ def _refresh_node_list_and_token_map(self, connection, preloaded_results=None,
             if not addr or addr in ["0.0.0.0", "::"]:
                 addr = row.get("peer")
 
+            tokens = row.get("tokens")
+            if not tokens:
+                log.warn("Excluding host (%s) with no tokens in system.peers table of %s." % (addr, connection.host))
+                continue
+
             found_hosts.add(addr)
 
             host = self._cluster.metadata.get_host(addr)
@@ -2073,7 +2078,6 @@ def _refresh_node_list_and_token_map(self, connection, preloaded_results=None,
             else:
                 should_rebuild_token_map |= self._update_location_info(host, datacenter, rack)
 
-            tokens = row.get("tokens")
             if partitioner and tokens:
                 token_map[host] = tokens
 
