From: Benjamin Braatz Date: Tue, 27 Jul 2021 09:46:28 +0000 (+0200) Subject: Conf changed message before writing. X-Git-Tag: v0.3.0~29 X-Git-Url: http://git.graph-it.com/?a=commitdiff_plain;h=b7addc27575f18e70732c4cf36928b7b8cf8e9f1;p=graphit%2Fcontrolpi.git Conf changed message before writing. --- diff --git a/controlpi/messagebus.py b/controlpi/messagebus.py index a3299cf..dcfe555 100644 --- a/controlpi/messagebus.py +++ b/controlpi/messagebus.py @@ -1189,9 +1189,9 @@ class MessageBus: if conf == message['conf']: await self._queue.put(Message('', {'event': 'conf unchanged'})) else: + await self._queue.put(Message('', {'event': 'conf changed'})) with open(sys.argv[1], 'w') as conf_file: json.dump(message['conf'], conf_file) - 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()