Update restore traffic method #290
1 changed files with 3 additions and 1 deletions
|
@ -325,6 +325,8 @@ class ClusterStateController:
|
||||||
node: ClusterNode,
|
node: ClusterNode,
|
||||||
) -> None:
|
) -> None:
|
||||||
IpHelper.restore_input_traffic_to_node(node=node)
|
IpHelper.restore_input_traffic_to_node(node=node)
|
||||||
|
index = self.dropped_traffic.index(node)
|
||||||
|
self.dropped_traffic.pop(index)
|
||||||
|
|
||||||
@reporter.step("Restore blocked nodes")
|
@reporter.step("Restore blocked nodes")
|
||||||
def restore_all_traffic(self):
|
def restore_all_traffic(self):
|
||||||
|
|
Loading…
Add table
Reference in a new issue