From 31acc90442cb1b60a9a2c9437c338c163ba0c260 Mon Sep 17 00:00:00 2001 From: cl0ete Date: Wed, 11 Dec 2024 16:45:35 +0200 Subject: [PATCH] :art: --- endorser/services/endorsement_processor.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) 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