openstack/deb-python-cassandra-driver
Code Issues Proposed changes

Handle missing/unrecognized replication strategy

Browse Source
This commit is contained in:
Tyler Hobbs
2014-01-09 16:34:33 -06:00
parent aab36b62cd
commit ec38b81feb
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
cassandra/metadata.py
View File

@@ -862,7 +862,10 @@ class TokenMap(object):
def replica_map_for_keyspace(self, ks_metadata): def replica_map_for_keyspace(self, ks_metadata):
strategy = ks_metadata.replication_strategy strategy = ks_metadata.replication_strategy
if strategy:
return strategy.make_token_replica_map(self.token_to_host_owner, self.ring) return strategy.make_token_replica_map(self.token_to_host_owner, self.ring)
else:
return None
def remove_keyspace(self, keyspace): def remove_keyspace(self, keyspace):
del self.tokens_to_hosts_by_ks[keyspace] del self.tokens_to_hosts_by_ks[keyspace]