diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index e01c824d59fee1ffd7344114a896bc53e9c3fcd4..9c877975e218cf5955370e171c26e3ccd5043492 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -96,7 +96,7 @@ def snmp_refresh_peerings(self, hostname, community, logical_systems): logger.exception(msg) self.log_warning(msg) r = get_current_redis(InventoryTask.config) - peerings = r.get(f'snmp-peerings:{hostname}') + peerings = r.get(f'snmp-peerings:{hostname}:all') if peerings is None: raise InventoryTaskError( f'snmp error with {peerings}' @@ -108,10 +108,12 @@ def snmp_refresh_peerings(self, hostname, community, logical_systems): r = get_next_redis(InventoryTask.config) rp = r.pipeline() - rp.set(f'snmp-peerings:{hostname}', json.dumps(peerings)) + rp.set(f'snmp-peerings:{hostname}:all', json.dumps(peerings)) for session in peerings: - rp.set(f'snmp-peerings:{session["remote"]}', json.dumps(session)) + rp.set( + f'snmp-peerings:{hostname}:{session["remote"]}', + json.dumps(session)) rp.execute()