feat: python2 -> python3

Author: zeidlitz

lib/diff.py

@@ -1,4 +1,3 @@
-import re
 import sys
 
 
@@ -61,10 +60,6 @@ def _print(color, msg, output):
 
 
 def compare_states(before, after, logging, output=sys.stdout, limit=10000):
-    # Did we detect _any_ changes?
-    changed = False
-
-    # Any new tables?
     tables_before = set(before['tables'])
     tables_after = set(after['tables'])
     dropped_tables = tables_before - tables_after
@@ -73,12 +68,10 @@ def compare_states(before, after, logging, output=sys.stdout, limit=10000):
         output.write('Dropped %d table(s):' % (len(dropped_tables)))
         for dropped_table in dropped_tables:
             _print(bcolors.FAIL, dropped_table, output)
-        changed = True
     if len(new_tables) > 0:
         output.write('Added %d table(s):' % (len(new_tables)))
         for added_table in new_tables:
             _print(bcolors.OKGREEN, added_table, output)
-        changed = True
 
     # We can only do diff magic on tables that were in both databases
     tables = tables_after.intersection(tables_before)
@@ -93,7 +86,6 @@ def compare_states(before, after, logging, output=sys.stdout, limit=10000):
         delta_count = count_after - count_before
         if delta_count != 0:
             logging.info('%s %d' % (table, delta_count))
-            changed = True
             removed_objects = objects_before - objects_after
             added_objects = objects_after - objects_before
             if len(removed_objects) > 0:

lib/firewall.py

@@ -77,7 +77,7 @@ def prefetch_node_and_services(self):
 
         self.node_services = dict()
         self.service_nodes = dict()
-        for access, access_key in access_to_sql_map.iteritems():
+        for access, access_key in access_to_sql_map.items():
             # TODO(bluecmd): These are deprecated in favor of packages
             # We should emit warnings in the presubmit hook to make sure
             # people are not using these
@@ -90,14 +90,14 @@ def prefetch_node_and_services(self):
             for node, service in explicit:
                 self.register_service(access, node, service)
 
-            for node, packset in self.nodes.iteritems():
+            for node, packset in self.nodes.items():
                 for package_name in packset:
                     package = self.packages[package_name] or {}
                     for service in set(package.get(access, [])):
                         self.register_service(access, node, service)
 
             # Prune redundant flows (hosts that share the network flows)
-            for node, services in self.node_services[access].iteritems():
+            for node in self.node_services[access].iteritems():
                 if node not in self.netmap:
                     continue
                 parent = self.node_services[access].get(self.netmap[node])