diff --git a/src/tqdm_publisher/_progress_subscriber.py b/src/tqdm_publisher/_progress_subscriber.py
index cfb6524..b892f4e 100644
--- a/src/tqdm_publisher/_progress_subscriber.py
+++ b/src/tqdm_publisher/_progress_subscriber.py
@@ -2,13 +2,13 @@
 
 
 class TQDMProgressSubscriber(TQDMPublisher):
-    def __init__(self, iterable, *,  announcer: "?", request_id: str, message: dict, **tqdm_kwargs):
+    def __init__(self, iterable, *, announcer: "?", request_id: str, message: dict, **tqdm_kwargs):
         super().__init__(iterable, **tqdm_kwargs)
 
         def on_progress_update(format_dict) -> None:
-             """
-             Describe what this announcer is all about...
-             """
-             announcer.announce(dict(request_id=request_id, **message))
-        
+            """
+            Describe what this announcer is all about...
+            """
+            announcer.announce(dict(request_id=request_id, **message))
+
         self.subscribe(callback=on_progress_update)