diff --git a/inventory_provider/tasks/ims_worker.py b/inventory_provider/tasks/ims_worker.py index d71c5b8976878458ff74755620c47ae8faa3309f..fdab630d459dbe9b7b082e3d920eae58996562ce 100644 --- a/inventory_provider/tasks/ims_worker.py +++ b/inventory_provider/tasks/ims_worker.py @@ -24,8 +24,12 @@ logger = logging.getLogger(__name__) @log_task_entry_and_exit def update_lg_routers_ims(self, use_current=False): - r = get_current_redis(InventoryTask.config) if use_current \ - else get_next_redis(InventoryTask.config) + if use_current: + r = get_current_redis(InventoryTask.config) + for k in r.scan_iter('classifier-cache:ims-lg:*'): + r.delete(k) + else: + r = get_next_redis(InventoryTask.config) for k in r.scan_iter('ims:lg:*'): r.delete(k)