From d29aa21769c99030096ad84e84875a2e41cc2f9b Mon Sep 17 00:00:00 2001 From: Alex Cannan Date: Fri, 15 Nov 2024 11:38:19 -0500 Subject: [PATCH] publish retries: 0.25s->1.0s; 3x->5x --- message_store/message_store.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/message_store/message_store.py b/message_store/message_store.py index 03f8a46..23d8267 100644 --- a/message_store/message_store.py +++ b/message_store/message_store.py @@ -101,10 +101,10 @@ async def publish_message( headers=headers, timeout=timeout_in_seconds, ), - max_retries=3, + max_retries=5, is_retriable=lambda e: isinstance(e, nats.js.errors.NoStreamResponseError) or (hasattr(e, "code") and e.code == 503), - initial_backoff_time_in_seconds=0.25, + initial_backoff_time_in_seconds=1.0, ) async def fetch(self, subject: str, projection: Projection):