diff --git a/endorser/services/endorsement_processor.py b/endorser/services/endorsement_processor.py
index b517e8b2b..59a211008 100644
--- 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