X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_policy_module%2Falarming%2Fservice.py;h=2ec78ccc4d3d45433bd2d60e90e9dd385d1bd422;hb=refs%2Fchanges%2F28%2F14028%2F1;hp=dbc375e426ca09ec69839fc369afec0057d29d89;hpb=be42d54170ca40d8d52e2c9fc8d888621585d6cf;p=osm%2FPOL.git diff --git a/osm_policy_module/alarming/service.py b/osm_policy_module/alarming/service.py index dbc375e..2ec78cc 100644 --- a/osm_policy_module/alarming/service.py +++ b/osm_policy_module/alarming/service.py @@ -22,7 +22,6 @@ # For those usages not covered by the Apache License, Version 2.0 please # contact: bdiaz@whitestack.com or glavado@whitestack.com ## -import asyncio import json import logging import operator @@ -47,14 +46,11 @@ log = logging.getLogger(__name__) class AlarmingService: - def __init__(self, config: Config, loop=None): + def __init__(self, config: Config): self.conf = config - if not loop: - loop = asyncio.get_event_loop() - self.loop = loop self.db_client = CommonDbClient(config) - self.mon_client = MonClient(config, loop=self.loop) - self.lcm_client = LcmClient(config, loop=self.loop) + self.mon_client = MonClient(config) + self.lcm_client = LcmClient(config) async def configure_vnf_alarms(self, nsr_id: str, vnf_member_index=None): log.info("Configuring vnf alarms for network service %s", nsr_id) @@ -132,6 +128,8 @@ class AlarmingService: threshold=alarm_descriptor["value"], operation=alarm_descriptor["operation"], action=str(alarm_action), + vnfr=vnfr, + vnfd=vnfd, ) alarm = VnfAlarmRepository.create( alarm_id=alarm_descriptor["alarm-id"],