From c85171f618a1889d904a9e28f67b8a37814ba1a4 Mon Sep 17 00:00:00 2001 From: Benjamin Braatz Date: Tue, 27 Jul 2021 05:38:51 +0200 Subject: [PATCH] Bugfix --- controlpi/messagebus.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/controlpi/messagebus.py b/controlpi/messagebus.py index d6b9cc8..a3299cf 100644 --- a/controlpi/messagebus.py +++ b/controlpi/messagebus.py @@ -1187,11 +1187,11 @@ class MessageBus: except (IndexError, FileNotFoundError, json.decoder.JSONDecodeError): pass if conf == message['conf']: - await self.bus.send(Message(self.name, {'event': 'unchanged'})) + await self._queue.put(Message('', {'event': 'conf unchanged'})) else: with open(sys.argv[1], 'w') as conf_file: json.dump(message['conf'], conf_file) - await self.bus.send(Message(self.name, {'event': 'changed'})) + await self._queue.put(Message('', {'event': 'conf changed'})) for client in self._recv_reg.get(message): await self._callbacks[client](message) self._queue.task_done() -- 2.34.1