@@ -83,27 +83,26 @@ def add_flow(self, data=None, flow_id=0, flow_type=FlowTypes.ACL, nodes_ids=[]):
8383
8484
8585 def del_flow (self , flow_id = 0 , nodes_ids = []):
86- """ Insert a try except to avoid code breakage when removing a non-existent acl"" "
86+ "Insert a try except to avoid code breakage when removing a non-existent acl"
8787
8888 try :
8989 return self ._flow (flow_id = flow_id , method = 'delete' , nodes_ids = nodes_ids )
9090
91- except Exception as err :
92- message = self ._parse_errors (err .response .json ())
93- log .error ("ERROR while removing a flow due to It does not exist anymore : %s" % message )
91+ except Exception as e :
92+ message = self ._parse_errors (e .response .json ())
93+ log .error ("ERROR while removing a flow: %s" % message )
9494 pass
9595
96-
9796 def update_all_flows (self , data , flow_type = FlowTypes .ACL ):
9897 current_flows = self .get_flows ()
9998
100- if flow_type == FlowTypes .ACL :
101- builder = AclFlowBuilder (data , self .environment , version = self .version )
102- new_flows_set = builder .build ()
103-
10499 for node in current_flows .keys ():
105100 log .info ("Starting update all flows for node %s" % node )
106101
102+ if flow_type == FlowTypes .ACL :
103+ builder = AclFlowBuilder (data , self .environment , version = self .version )
104+ new_flows_set = builder .build ()
105+
107106 #Makes a diff
108107 operations = self ._diff_flows (current_flows [node ], new_flows_set )
109108
0 commit comments