diff --git a/inventory_provider/tasks/ims_worker.py b/inventory_provider/tasks/ims_worker.py
index e966d228ae15c05101624e79f5a448935fc3d75c..b2f2bec368cdf5858bf0890387293689596cb45c 100644
--- a/inventory_provider/tasks/ims_worker.py
+++ b/inventory_provider/tasks/ims_worker.py
@@ -24,17 +24,16 @@ logger = logging.getLogger(__name__)
 @app.task(base=InventoryTask, bind=True, name='update_equipment_locations_ims')
 @log_task_entry_and_exit
 def update_equipment_locations_ims(self, use_current=False):
-    r = get_current_redis(InventoryTask.config)
 
     if use_current:
         r = get_current_redis(InventoryTask.config)
-        rp = r.pipeline()
         # scan with bigger batches, to mitigate network latency effects
-        for k in r.scan_iter('ims:location:*', count=1000):
-            rp.delete(k)
-        rp.execute()
     else:
         r = get_next_redis(InventoryTask.config)
+    rp = r.pipeline()
+    for k in r.scan_iter('ims:location:*', count=1000):
+        rp.delete(k)
+    rp.execute()
 
     c = InventoryTask.config["ims"]
     ds = IMS(c['api'], c['username'], c['password'])