X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FMON.git;a=blobdiff_plain;f=osm_mon%2Fserver%2Fserver.py;fp=osm_mon%2Fserver%2Fserver.py;h=bb8f0e8c37a3fa61406e5f950a39ae73b1df6494;hp=f05cdec788b18b5b6a0d5017cf82339f2c72b339;hb=072b0bdeb1a0919c5cc8de128fa3c62e8393ed7c;hpb=ca2fd226036f433ba97c427fbfdb08e2a339ab08 diff --git a/osm_mon/server/server.py b/osm_mon/server/server.py index f05cdec..bb8f0e8 100755 --- a/osm_mon/server/server.py +++ b/osm_mon/server/server.py @@ -37,17 +37,14 @@ 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"]