From 380ccd781fef5b1ee98e9660c748c8955d3bf40e Mon Sep 17 00:00:00 2001 From: Eugene Crosser Date: Sat, 28 May 2022 20:14:25 +0200 Subject: [PATCH] typechecking: annotate termconfig.py --- gps303/termconfig.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/gps303/termconfig.py b/gps303/termconfig.py index b9517f0..eb3150b 100644 --- a/gps303/termconfig.py +++ b/gps303/termconfig.py @@ -1,5 +1,6 @@ """ For when responding to the terminal is not trivial """ +from configparser import ConfigParser from datetime import datetime, timezone from logging import getLogger from struct import pack @@ -12,10 +13,11 @@ from .zmsg import Bcast, Resp, topic log = getLogger("gps303/termconfig") -def runserver(conf): +def runserver(conf: ConfigParser) -> None: termconfig = common.normconf(conf["termconfig"]) - zctx = zmq.Context() - zsub = zctx.socket(zmq.SUB) + # Is this https://github.com/zeromq/pyzmq/issues/1627 still not fixed?! + zctx = zmq.Context() # type: ignore + zsub = zctx.socket(zmq.SUB) # type: ignore zsub.connect(conf.get("collector", "publishurl")) for proto in ( STATUS.PROTO, @@ -23,7 +25,7 @@ def runserver(conf): POSITION_UPLOAD_INTERVAL.PROTO, ): zsub.setsockopt(zmq.SUBSCRIBE, topic(proto)) - zpush = zctx.socket(zmq.PUSH) + zpush = zctx.socket(zmq.PUSH) # type: ignore zpush.connect(conf.get("collector", "listenurl")) try: -- 2.39.2