[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

src/tqdm_publisher/__init__.py

@@ -1,5 +1,5 @@
-from ._publisher import TQDMPublisher
-from ._progress_subscriber import TQDMProgressSubscriber
 from ._progress_handler import TQDMProgressHandler
+from ._progress_subscriber import TQDMProgressSubscriber
+from ._publisher import TQDMPublisher
 
 __all__ = ["TQDMPublisher", "TQDMProgressSubscriber", "TQDMProgressHandler"]

src/tqdm_publisher/_progress_handler.py

@@ -1,6 +1,8 @@
 import queue
+
 from ._progress_subscriber import TQDMProgressSubscriber
 
+
 class TQDMProgressHandler:
     def __init__(self):
         self.listeners = []
@@ -9,16 +11,17 @@ def listen(self):
         q = queue.Queue(maxsize=25)
         self.listeners.append(q)
         return q
-    
+
     def create(self, iterable, additional_metadata: dict = dict(), **tqdm_kwargs):
-        return TQDMProgressSubscriber(iterable, lambda progress_update: self._announce(dict(
-            **progress_update,
-            **additional_metadata
-        )), **tqdm_kwargs)
+        return TQDMProgressSubscriber(
+            iterable,
+            lambda progress_update: self._announce(dict(**progress_update, **additional_metadata)),
+            **tqdm_kwargs,
+        )
 
     def _announce(self, msg):
         for i in reversed(range(len(self.listeners))):
             try:
                 self.listeners[i].put_nowait(msg)
             except queue.Full:
-                del self.listeners[i]
+                del self.listeners[i]

src/tqdm_publisher/_progress_subscriber.py

@@ -1,6 +1,7 @@
 from ._publisher import TQDMPublisher
 
+
 class TQDMProgressSubscriber(TQDMPublisher):
     def __init__(self, iterable, on_progress_update: callable, **tqdm_kwargs):
         super().__init__(iterable, **tqdm_kwargs)
-        self.subscribe(lambda format_dict: on_progress_update(dict(progress_bar_id=self.id, format_dict=format_dict)))
+        self.subscribe(lambda format_dict: on_progress_update(dict(progress_bar_id=self.id, format_dict=format_dict)))