From: Eugene Crosser Date: Sat, 28 May 2022 18:24:57 +0000 (+0200) Subject: typeckecking: annotate storage.py X-Git-Tag: 0.96~7 X-Git-Url: http://www.average.org/gitweb/?p=loctrkd.git;a=commitdiff_plain;h=7f904a11263dc04df2110c36444522ea622367d4 typeckecking: annotate storage.py --- diff --git a/gps303/storage.py b/gps303/storage.py index 14afc49..b6f84ce 100644 --- a/gps303/storage.py +++ b/gps303/storage.py @@ -1,5 +1,6 @@ """ Store zmq broadcasts to sqlite """ +from configparser import ConfigParser from datetime import datetime, timezone from logging import getLogger import zmq @@ -12,12 +13,13 @@ from .zmsg import Bcast log = getLogger("gps303/storage") -def runserver(conf): +def runserver(conf: ConfigParser) -> None: dbname = conf.get("storage", "dbfn") log.info('Using Sqlite3 database "%s"', dbname) initdb(dbname) - 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")) zsub.setsockopt(zmq.SUBSCRIBE, b"")