Update mqtt.py

jpmens · Jul 10, 2023 · 3463b2f · 3463b2f
1 parent ac44276
commit 3463b2f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugins/event_source/mqtt.py b/plugins/event_source/mqtt.py
@@ -70,7 +70,7 @@ async def main(queue: asyncio.Queue, args: dict[str, Any]) -> None:
                 try:
                     data = json.loads(message.payload.decode())
                     await queue.put(data)
-                except json.decoder.JSONDecodeError as e:
+                except json.decoder.JSONDecodeError:
                     logger.exception("Decoding exception for incoming message")
     finally:
         logger.info("Disconneccting from broker")