From 88a3afa6164974a700e775fcd924dc25eca166e6 Mon Sep 17 00:00:00 2001 From: kubealex Date: Sat, 26 Aug 2023 16:44:49 +0200 Subject: [PATCH] align typing --- plugins/event_source/mqtt.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/plugins/event_source/mqtt.py b/plugins/event_source/mqtt.py index 5ebdc33..12c50af 100644 --- a/plugins/event_source/mqtt.py +++ b/plugins/event_source/mqtt.py @@ -25,19 +25,19 @@ import asyncio import json import logging -from typing import Any, dict +from typing import Any, Dict import aiomqtt as aiomqtt -async def main(queue: asyncio.Queue, args: dict[str, Any]) -> None: +async def main(queue: asyncio.Queue, args: Dict[str, Any]) -> None: """Receive events via a MQTT topic.""" logger = logging.getLogger() topic = args.get("topic") host = args.get("host") - port = args.get("port") + port = int(args.get("port")) username = args.get("username") password = args.get("password")