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