diff --git a/utils/containers.py b/utils/containers.py index bead8fe66924c0b1f76dafa674de7961884b6275..efc6ebf263fdde5acd8c21304caff3d35d7e0785 100644 --- a/utils/containers.py +++ b/utils/containers.py @@ -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")