added, removed, updated = compute_dict_delta(self.backend_replicas,
backend_configs)
for backend_tag, config in ChainMap(added, updated).items():
self.backend_replicas[backend_tag].set_max_concurrent_queries(
config.max_concurrent_queries)
for backend_tag in removed.keys():
After Change
added, removed, updated = compute_dict_delta(self.backend_replicas,
backend_configs)
for backend_tag, config in ChainMap(added, updated).items():
self._get_or_create_replica_set(
backend_tag).set_max_concurrent_queries(
config.max_concurrent_queries)