diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index 557de117746f5ada76870609356f3f098789a452..246b532bb622a413f6c33d866f564d5b945936ff 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -125,19 +125,20 @@ def update_access_services(self): with db.connection(InventoryTask.config["ops-db"]) as cx: for service in opsdb.get_access_services(cx): - if service['equipment'] in access_services: + if service['name'] in access_services: logger.warning( - f'got multiple access services for {service["equipment"]}') + 'got multiple access services ' + f'with name "{service["name"]}"') - access_services[service['equipment']] = service + access_services[service['name']] = service r = get_next_redis(InventoryTask.config) for key in r.scan_iter('opsdb:access_services:*'): r.delete(key) rp = r.pipeline() - for equipment_interface, service in access_services.items(): + for name, service in access_services.items(): rp.set( - f'opsdb:access_services:{equipment_interface}', + f'opsdb:access_services:{name}', json.dumps(service)) rp.execute()