🎨

didx-xyz · Dec 11, 2024 · 31acc90 · 31acc90
1 parent 0a44045
commit 31acc90
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/endorser/services/endorsement_processor.py b/endorser/services/endorsement_processor.py
@@ -189,10 +189,10 @@ async def _subscribe(self) -> JetStreamContext.PullSubscription:
         """
         logger.info("Subscribing to NATS subject: {}", self.endorser_nats_subject)
         subscribe_kwargs = {
-                "subject": self.endorser_nats_subject,
-                "durable": ENDORSER_DURABLE_CONSUMER,
-                "stream": NATS_STREAM,
-            }
+            "subject": self.endorser_nats_subject,
+            "durable": ENDORSER_DURABLE_CONSUMER,
+            "stream": NATS_STREAM,
+        }
 
         @retry(
             retry=retry_if_exception_type(TimeoutError),
@@ -211,6 +211,7 @@ async def pull_subscribe(**kwargs):
             except Exception:  # pylint: disable=W0703
                 logger.exception("Unknown error subscribing to NATS subject")
                 raise
+
         try:
             return await pull_subscribe(**subscribe_kwargs)
         except Exception:  # pylint: disable=W0703