diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index ef2850a478c89fb5ae29281016bf0dcd9a49b0dd..557de117746f5ada76870609356f3f098789a452 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -125,23 +125,20 @@ def update_access_services(self): with db.connection(InventoryTask.config["ops-db"]) as cx: for service in opsdb.get_access_services(cx): - equipment_interface = '%s:%s' % ( - service['equipment'], service['interface_name']) - - if equipment_interface in access_services: + if service['equipment'] in access_services: logger.warning( - f'got multiple access services for {equipment_interface}') + f'got multiple access services for {service["equipment"]}') - access_services[equipment_interface] = service + access_services[service['equipment']] = 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, services in access_services.items(): + for equipment_interface, service in access_services.items(): rp.set( f'opsdb:access_services:{equipment_interface}', - json.dumps(services)) + json.dumps(service)) rp.execute() logger.debug('<<< update_access_services')