Merge pull request pycassa#105 from carlopires/patch-1

Fix for _wait_for_agreement in system manager.
bshanks · Jan 4, 2012 · cb8eae9 · cb8eae9
2 parents 2909e95 + e969907
commit cb8eae9
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/pycassa/system_manager.py b/pycassa/system_manager.py
@@ -589,6 +589,11 @@ def drop_index(self, keyspace, column_family, column):
     def _wait_for_agreement(self):
         while True:
             versions = self._conn.describe_schema_versions()
-            if len(versions) == 1:
-                break
-            time.sleep(_SAMPLE_PERIOD)
+
+            # ignore unreachable nodes
+            live_versions = [key for key in versions.keys() if key != 'UNREACHABLE']
+
+            if len(live_versions) == 1:
+               break
+            else:
+                time.sleep(_SAMPLE_PERIOD)