From 509acdf47a2877be602924b05a62d170a15e4607 Mon Sep 17 00:00:00 2001 From: Benjamin Braatz Date: Wed, 8 Sep 2021 14:44:44 +0200 Subject: [PATCH] Only send message if bus client callback still there. --- controlpi/messagebus.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/controlpi/messagebus.py b/controlpi/messagebus.py index 4ff3453..b320245 100644 --- a/controlpi/messagebus.py +++ b/controlpi/messagebus.py @@ -1177,7 +1177,8 @@ class MessageBus: with open(sys.argv[1], 'w') as conf_file: json.dump(message['conf'], conf_file) for client in self._recv_reg.get(message): - await self._callbacks[client](message) + if client in self._callbacks: + await self._callbacks[client](message) self._queue.task_done() async def send(self, message: Message) -> None: -- 2.34.1