pep8

inventory_provider/tasks/worker.py

@@ -440,6 +440,13 @@ def _derive_router_hostnames(config):
 
 
 def _erase_next_db(config):
+    """
+    flush next db, but first save latch and then restore afterwards
+
+    TODO: handle the no latch scenario nicely
+    :param config:
+    :return:
+    """
     r = get_next_redis(config)
     saved_latch = get_latch(r)
     r.flushdb()
@@ -449,6 +456,7 @@ def _erase_next_db(config):
             new_current=saved_latch['current'],
             new_next=saved_latch['next'])
 
+
 def launch_refresh_cache_all(config):
     """
     utility function intended to be called outside of the worker process