2.1.48

🔧 fix(exch_srv): Handle `RateLimitReached` exception in `OpenClientConnection` gracefully
♻️ chore(requirements): Update `crypto-ws-api` to version 2.1.8
♻️ chore(requirements): Upgrade `aiohttp` to version 3.13.4
📝 docs(changelog): Update changelog for version 2.1.48

Author: DogsTailFarmer

CHANGELOG.md

@@ -1,3 +1,8 @@
+## 2.1.48 2026-04-03
+🔧 fix(exch_srv): Handle `RateLimitReached` exception in `OpenClientConnection` gracefully  
+♻️ chore(requirements): Update `crypto-ws-api` to version 2.1.8  
+♻️ chore(requirements): Upgrade `aiohttp` to version 3.13.4  
+
 ## 2.1.47 2026-03-08
 ♻️ chore(version): Bump **crypto-ws-api** to 2.1.7 and update version to 2.1.47 in **CHANGELOG.md**
 

exchanges_wrapper/__init__.py

@@ -12,7 +12,7 @@
 __contact__ = "https://github.com/DogsTailFarmer"
 __email__ = "jerry.fedorenko@yahoo.com"
 __credits__ = ["https://github.com/DanyaSWorlD"]
-__version__ = "2.1.47"
+__version__ = "2.1.48"
 
 from pathlib import Path
 import shutil

exchanges_wrapper/exch_srv.py

@@ -39,6 +39,7 @@
     OnTickerUpdateResponse,
     FetchOrderBookResponse,
 )
+from exchanges_wrapper.errors import RateLimitReached
 #
 HEARTBEAT = 1  # sec
 MAX_QUEUE_SIZE = 100
@@ -137,6 +138,16 @@ async def open_client_connection(self, request: mr.OpenClientConnectionRequest)
             await OpenClient.get_client(client_id).client.http.close_session()
             OpenClient.remove_client(client_id)
             raise GRPCError(status=Status.UNAVAILABLE, message=f"'{open_client.name}' timeout error")
+        except RateLimitReached:
+            await OpenClient.get_client(client_id).client.http.close_session()
+            OpenClient.remove_client(client_id)
+            logger.warning(f"OpenClientConnection LOADS for {open_client.name}: {RateLimitReached.message},"
+                           f" trying some later")
+            await asyncio.sleep(HEARTBEAT * 60)
+            raise GRPCError(
+                status=Status.RESOURCE_EXHAUSTED,
+                message=f"'{open_client.name}: {RateLimitReached.message}'"
+            )
         except Exception as ex:
             logger.warning(f"OpenClientConnection for '{open_client.name}' exception: {ex}")
             logger.debug(f"Exception traceback: {traceback.format_exc()}")

pyproject.toml

@@ -20,10 +20,10 @@ dynamic = ["version", "description"]
 requires-python = ">=3.10"
 
 dependencies = [
-    "crypto-ws-api==2.1.7",
+    "crypto-ws-api==2.1.8",
     "pyotp==2.9.0",
     "simplejson==3.20.2",
-    "aiohttp~=3.13.3",
+    "aiohttp~=3.13.4",
     "expiringdict~=1.2.2",
     "betterproto==2.0.0b7",
     "grpclib~=0.4.8"

requirements.txt

@@ -1,7 +1,7 @@
-crypto-ws-api==2.1.7
+crypto-ws-api==2.1.8
 pyotp==2.9.0
 simplejson==3.20.2
-aiohttp~=3.13.3
+aiohttp~=3.13.4
 expiringdict~=1.2.2
 betterproto==2.0.0b7
 grpclib~=0.4.8