From c4fb15091fe2e4ba8e0e31e8a4496247078a4eb5 Mon Sep 17 00:00:00 2001
From: Erik Reid <erik.reid@geant.org>
Date: Tue, 10 Mar 2020 11:30:51 +0100
Subject: [PATCH] use service name in redis key
---
inventory_provider/tasks/worker.py | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py
index 557de117..246b532b 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()
--
GitLab