flush next db before running jobs

inventory_provider/tasks/worker.py

@@ -441,6 +441,9 @@ def launch_refresh_cache_all(config):
     """
     logger = logging.getLogger(__name__)
 
+    r = get_next_redis(InventoryTask.config)
+    r.flushdb()
+
     # first batch of subtasks: refresh cached opsdb data
     subtasks = [
         update_junosspace_device_list.apply_async(),