diff --git a/utils/containers.py b/utils/containers.py index efc6ebf263fdde5acd8c21304caff3d35d7e0785..afe3eb45b98cb770102602475edaca0131c3bdb5 100644 --- a/utils/containers.py +++ b/utils/containers.py @@ -433,6 +433,7 @@ class ClusterConductor: # update node ip if container_ip != node.ip: + self.log(f"Warning: Node {i} IP addr changed from {node.ip} to {container_ip}") node.ip = container_ip if hasattr(self, "_parent"): self._parent.clients[ @@ -499,14 +500,15 @@ class ClusterConductor: # update node ip if container_ip != node.ip: + self.log(f"Warning: Node {i} IP addr changed from {node.ip} to {container_ip}") node.ip = container_ip if hasattr(self, "_parent"): self._parent.clients[ 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")