diff --git a/inventory_provider/routes/msr.py b/inventory_provider/routes/msr.py index b85c5771a25863ec805d57ef306acdcc6ae930d2..e5e4fa9af4ccca6bc57d8cef7cd601dc2f302d0f 100644 --- a/inventory_provider/routes/msr.py +++ b/inventory_provider/routes/msr.py @@ -159,7 +159,7 @@ def access_services(): redis = common.get_current_redis() def _services(): - for k in redis.scan_iter('ims:access_services:*'): + for k in redis.scan_iter('ims:services:access_services:*'): service = redis.get(k.decode('utf-8')).decode('utf-8') service = json.loads(service) @@ -212,7 +212,7 @@ def gws_indirect(): redis = common.get_current_redis() def _services(): - for k in redis.scan_iter('ims:gws_indirect:*'): + for k in redis.scan_iter('ims:services:gws_indirect:*'): service = redis.get(k.decode('utf-8')).decode('utf-8') service = json.loads(service) yield { diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index a29f710f99f30a4c81bab2d786f37e7bc8090707..5de676cf147915a21f5c1770ffc112c8e5d3e939 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -806,7 +806,7 @@ def update_circuit_hierarchy_and_port_id_services(self, use_current=False): for service_type, services in services_by_type.items(): for v in services.values(): rp.set( - f'ims:{service_type}:{v["name"]}', + f'ims:services:{service_type}:{v["name"]}', json.dumps({ 'id': v['id'], 'name': v['name'],