diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index 7a187b4f61fef3b15f6fb0e7f6163e32443d4c6d..26dfbba59ff5fecc0552530ffdc6d6a9e1fdd145 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -144,7 +144,7 @@ def update_equipment_locations(): for key in r.scan_iter('opsdb:location:*'): r.delete(key) with db.connection(InventoryTask.config["ops-db"]) as cx: - for ld in opsdb.get_equipment_location_data(cx): + for ld in opsdb.lookup_pop_info(cx): r.set('opsdb:location:%s' % ld['equipment_name'], json.dumps(ld)) logger.debug('<<< update_equipment_locations')