diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index 075660cbecc731b4e5cda344d437a9ebaa7c01e2..c2bb2b1142b9d3d59d43b54ed9cb6ea3690e24ad 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -123,6 +123,10 @@ def update_interfaces_to_services(): equipment_interface = '%s:%s' % ( service['equipment'], service['interface_name']) interface_services[equipment_interface].append(service) + if "." in service['interface_name']: + equipment_interface = '%s:%s' % ( + service['equipment'], service['interface_name'].split(".")[0]) + interface_services[equipment_interface].append(service) r = get_redis(InventoryTask.config) for key in r.scan_iter('opsdb:interface_services:*'):