diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py
index 33d49fac53ea209f842d7fcac8992c8ed80a90f4..88dbfc6924a6d6bcd934b36edb9975260b5ee0c7 100644
--- a/inventory_provider/tasks/worker.py
+++ b/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(),