clean code

simonsobs · Jul 20, 2022 · 927ade3 · 927ade3
1 parent a0cb86a
commit 927ade3
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/nextline/utils/pubsub/broker.py b/nextline/utils/pubsub/broker.py
@@ -12,10 +12,11 @@
 class PubSub(Generic[_KT, _VT]):
     """Asynchronous message broker of the publish-subscribe pattern"""
 
-    def __init__(self, *args, **kwargs):
-        self._queue: DefaultDict[_KT, PubSubItem[_VT]] = defaultdict(
-            PubSubItem
-        )
+    def __init__(self):
+        self._queue: DefaultDict[
+            _KT,
+            PubSubItem[_VT],
+        ] = defaultdict(PubSubItem)
 
     def subscribe(
         self, key: _KT, last: Optional[bool] = True