Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

Merge pull request #105 from carlopires/patch-1

Fix for _wait_for_agreement in system manager.
  • Loading branch information...
commit cb8eae9c9fa0976b2ba33648f95df2ab438e014b 2 parents 2909e95 + e969907
@thobbs thobbs authored
Showing with 8 additions and 3 deletions.
  1. +8 −3 pycassa/system_manager.py
View
11 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)
Please sign in to comment.
Something went wrong with that request. Please try again.