X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fserver%2Fserver.py;h=bb8f0e8c37a3fa61406e5f950a39ae73b1df6494;hb=refs%2Fchanges%2F01%2F13801%2F2;hp=962a6f9cedd816626371275224b600221fa74506;hpb=a353daa53d1b4d8da6fcbfefd40f309a5cf33688;p=osm%2FMON.git

diff --git a/osm_mon/server/server.py b/osm_mon/server/server.py
index 962a6f9..bb8f0e8 100755
--- a/osm_mon/server/server.py
+++ b/osm_mon/server/server.py
@@ -37,24 +37,20 @@ log = logging.getLogger(__name__)
 
 
 class Server:
-    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.msg_bus = MessageBusClient(config)
         self.service = ServerService(config)
         self.service.populate_prometheus()
 
     def run(self):
-        self.loop.run_until_complete(self.start())
+        asyncio.run(self.start())
 
     async def start(self, wait_time=5):
         topics = ["alarm_request"]
         while True:
             try:
                 await self.msg_bus.aioread(topics, self._process_msg)
-                log.info("Sucessfully subscribed to kafka topic(s) %s", str(topics))
                 break
             except Exception as e:
                 # Failed to subscribe to kafka topic
@@ -67,7 +63,6 @@ class Server:
     async def _process_msg(self, topic, key, values):
         log.info("Message arrived: %s", values)
         try:
-
             if topic == "alarm_request":
                 if key == "create_alarm_request":
                     alarm_details = values["alarm_create_request"]