Skip to content

Commit 0acc0b6

Browse files
committed
Adds additional exception for catching
1 parent 682e266 commit 0acc0b6

File tree

3 files changed

+8
-2
lines changed

3 files changed

+8
-2
lines changed

async_substrate_interface/async_substrate.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@
3939
SubstrateRequestException,
4040
ExtrinsicNotFound,
4141
BlockNotFound,
42+
MaxRetriesExceeded,
4243
)
4344
from async_substrate_interface.types import (
4445
ScaleObj,
@@ -1910,7 +1911,7 @@ async def _make_rpc_request(
19101911
logger.warning(
19111912
f"Timed out waiting for RPC requests {attempt} times. Exiting."
19121913
)
1913-
raise SubstrateRequestException("Max retries reached.")
1914+
raise MaxRetriesExceeded("Max retries reached.")
19141915
else:
19151916
self.ws.last_received = time.time()
19161917
await self.ws.connect(force=True)

async_substrate_interface/errors.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,10 @@ class SubstrateRequestException(Exception):
88
pass
99

1010

11+
class MaxRetriesExceeded(SubstrateRequestException):
12+
pass
13+
14+
1115
class StorageFunctionNotFound(ValueError):
1216
pass
1317

async_substrate_interface/sync_substrate.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
ExtrinsicNotFound,
2222
SubstrateRequestException,
2323
BlockNotFound,
24+
MaxRetriesExceeded,
2425
)
2526
from async_substrate_interface.types import (
2627
SubstrateMixin,
@@ -1611,7 +1612,7 @@ def _make_rpc_request(
16111612
logger.warning(
16121613
f"Timed out waiting for RPC requests {attempt} times. Exiting."
16131614
)
1614-
raise SubstrateRequestException("Max retries reached.")
1615+
raise MaxRetriesExceeded("Max retries reached.")
16151616
else:
16161617
return self._make_rpc_request(
16171618
payloads,

0 commit comments

Comments
 (0)