Skip to content
Snippets Groups Projects
Commit b7427479 authored by ananyabalagere's avatar ananyabalagere
Browse files

revert ipaddr rebroadcast

parent dd37afc6
No related branches found
No related tags found
No related merge requests found
......@@ -439,8 +439,9 @@ class ClusterConductor:
node.index
].base_url = self.node_external_endpoint(node.index)
view_changed = True
if view_changed and hasattr(self, "_parent"):
self._parent.rebroadcast_view(self.get_shard_view())
# if view_changed and hasattr(self, "_parent"):
# self._parent.rebroadcast_view(self.get_shard_view())
def create_partition(self, node_ids: List[int], partition_id: str) -> None:
net_name = f"kvs_{self.group_id}_net_{partition_id}"
......@@ -504,8 +505,8 @@ class ClusterConductor:
node.index
].base_url = self.node_external_endpoint(node.index)
view_changed = True
if view_changed and hasattr(self, "_parent"):
self._parent.rebroadcast_view(self.get_shard_view())
# if view_changed and hasattr(self, "_parent"):
# self._parent.rebroadcast_view(self.get_shard_view())
DeprecationWarning("View is in updated format")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment