diff --git a/tempermonitor/plugins/collectd.py b/tempermonitor/plugins/collectd.py index d050634108329438ec6014bdad859bcbc9dc8df3..4c6e91067a0a54ee6a1a49c046a5f879e5c85b63 100644 --- a/tempermonitor/plugins/collectd.py +++ b/tempermonitor/plugins/collectd.py @@ -10,11 +10,10 @@ class Collectd(Plugin): """ def __init__(self, monitor): - self.loop = asyncio.get_event_loop() self.config = monitor.config self.path = self.config['collectd']['socketpath'] self._reader, self._writer = (None, None) - self.loop.run_until_complete(self.reconnect()) + asyncio.run(self.reconnect()) self.monitor = monitor @@ -28,8 +27,7 @@ class Collectd(Plugin): self._writer.close() self._reader, self._writer = await asyncio.open_unix_connection( - path=self.path, - loop=self.loop) + path=self.path) async def _send(self, identifier, interval, timestamp, value): """