From 47451bf740c87c3bde729c9a26f71760e00906a5 Mon Sep 17 00:00:00 2001 From: ff137 Date: Wed, 11 Dec 2024 17:30:03 +0200 Subject: [PATCH] :bug: Endorser should fetch 1 message at a time --- endorser/services/endorsement_processor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/endorser/services/endorsement_processor.py b/endorser/services/endorsement_processor.py index c4e509b1e..e6025312a 100644 --- a/endorser/services/endorsement_processor.py +++ b/endorser/services/endorsement_processor.py @@ -86,7 +86,7 @@ async def _process_endorsement_requests(self) -> NoReturn: subscription = await self._subscribe() while True: try: - messages = await subscription.fetch(batch=3, timeout=1, heartbeat=0.4) + messages = await subscription.fetch(batch=1, timeout=1, heartbeat=0.4) for message in messages: message_subject = message.subject message_data = message.data.decode()