Skip to content
This repository has been archived by the owner on Aug 4, 2020. It is now read-only.

Commit

Permalink
Fix for _wait_for_agreement in system manager. Now it works if some c…
Browse files Browse the repository at this point in the history
…luster's node is down.
  • Loading branch information
carlopires committed Jan 2, 2012
1 parent 2909e95 commit b5f9e4c
Showing 1 changed file with 7 additions and 2 deletions.
9 changes: 7 additions & 2 deletions pycassa/system_manager.py
Expand Up @@ -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
for key, _nodes in versions.items():
try:
uuid.UUID(key)
except:
continue
else:
return True
time.sleep(_SAMPLE_PERIOD)

0 comments on commit b5f9e4c

Please sign in to comment.