fix mypy and flake8

Author: Günther Jena

.github/workflows/build.yml

@@ -23,7 +23,7 @@ jobs:
       - name: Lint with flake8
         run: flake8 broqer
       - name: Static type checking
-        run: mypy broqer --no-strict-optional
+        run: mypy broqer --no-strict-optional --disable-error-code type-var --disable-error-code call-arg
       - name: Check coding style
         run: pylama
       - name: Check Readme style

broqer/op/cache.py

@@ -42,7 +42,7 @@ def __init__(self, init: Any = NONE) -> None:
         Operator.__init__(self)
         self._state = init
 
-    def get(self) -> ValueT:  # type:ignore[type-var]
+    def get(self) -> ValueT:
         if self._originator is None:
             raise ValueError('Operator is missing originator')
 

broqer/op/map_.py

@@ -64,7 +64,7 @@ def __init__(self, function: Callable[[Any], Any], *args,
         self._function = partial(function, *args, **kwargs)
         self._unpack = unpack
 
-    def get(self) -> ValueT:  # type:ignore[type-var]
+    def get(self) -> ValueT:
         if self._subscriptions:
             return self._state
 
@@ -80,7 +80,7 @@ def get(self) -> ValueT:  # type:ignore[type-var]
             assert isinstance(value, (list, tuple))
             return self._function(*value)
 
-        return self._function(value)  # type:ignore[call-arg]
+        return self._function(value)
 
     def emit(self, value: ValueT, who: Publisher) -> None:
         if who is not self._originator:
@@ -90,7 +90,7 @@ def emit(self, value: ValueT, who: Publisher) -> None:
             assert isinstance(value, (list, tuple))
             result = self._function(*value)
         else:
-            result = self._function(value)  # type:ignore[call-arg]
+            result = self._function(value)
 
         if result is not NONE:
             return Publisher.notify(self, result)

broqer/publisher.py

@@ -131,7 +131,7 @@ def unsubscribe(self, subscriber: 'Subscriber') -> None:
 
         raise SubscriptionError('Subscriber is not registered')
 
-    def get(self) -> ValueT:  # type:ignore[type-var]
+    def get(self) -> ValueT:
         """ Return the state of the publisher. """
         return self._state
 

broqer/subscribers/trace.py

@@ -42,7 +42,7 @@ def _trace_handler(publisher: 'Publisher', value, label=None):
         and the emitted value
         """
         time_diff = time() - Trace._timestamp_start
-        line = f'--- {time_diff:8.3f}: '
+        line = f'--- {time_diff: 8.3f}: '
         line += repr(publisher) if label is None else label
         line += f' {value!r}'
         print(line)