From 835853cbd0b5c4451a72d32511c7ba7f60692a09 Mon Sep 17 00:00:00 2001 From: wdbasson Date: Mon, 4 Nov 2024 17:34:20 +0200 Subject: [PATCH] Test 2 second timeout --- 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 28d550614b..40536ffc84 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=1, timeout=60, heartbeat=1) + messages = await subscription.fetch(batch=1, timeout=2, heartbeat=1) for message in messages: message_subject = message.subject message_data = message.data.decode()