From 50131f7946375986504929b30b35e12f3b7cc241 Mon Sep 17 00:00:00 2001 From: Mike Shultz Date: Wed, 11 Sep 2024 14:10:01 -0600 Subject: [PATCH 1/2] chore: make sure websocket timeouts are logged as warnings --- silverback/subscriptions.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/silverback/subscriptions.py b/silverback/subscriptions.py index 087eaf87..269742d5 100644 --- a/silverback/subscriptions.py +++ b/silverback/subscriptions.py @@ -148,7 +148,7 @@ async def get_subscription_data_nowait( try: await self._receive(timeout=timeout) except TimeoutError: - logger.debug("Receive call timed out.") + logger.warning("Receive call timed out.") return else: try: From 8c22759daf831ea4ad10206b0925e1a1df1d4e9a Mon Sep 17 00:00:00 2001 From: Mike Shultz Date: Wed, 11 Sep 2024 14:16:30 -0600 Subject: [PATCH 2/2] chore: include sub_id in timeout warning --- silverback/subscriptions.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/silverback/subscriptions.py b/silverback/subscriptions.py index 269742d5..6aa42e44 100644 --- a/silverback/subscriptions.py +++ b/silverback/subscriptions.py @@ -148,7 +148,7 @@ async def get_subscription_data_nowait( try: await self._receive(timeout=timeout) except TimeoutError: - logger.warning("Receive call timed out.") + logger.warning(f"Receive call timed out ({sub_id}).") return else: try: