Merge "sharding: better handle get_shard_ranges failures"
This commit is contained in:
commit
a563f4f5a6
@ -138,7 +138,7 @@ class ContainerReplicator(db_replicator.Replicator):
|
|||||||
def _fetch_and_merge_shard_ranges(self, http, broker):
|
def _fetch_and_merge_shard_ranges(self, http, broker):
|
||||||
with Timeout(self.node_timeout):
|
with Timeout(self.node_timeout):
|
||||||
response = http.replicate('get_shard_ranges')
|
response = http.replicate('get_shard_ranges')
|
||||||
if is_success(response.status):
|
if response and is_success(response.status):
|
||||||
broker.merge_shard_ranges(json.loads(
|
broker.merge_shard_ranges(json.loads(
|
||||||
response.data.decode('ascii')))
|
response.data.decode('ascii')))
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user