Skip to content

Commit ce855da

Browse files
committed
Adjust sleep wait
1 parent 7420723 commit ce855da

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

async_substrate_interface/async_substrate.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -673,7 +673,7 @@ async def retrieve(self, item_id: int) -> Optional[dict]:
673673
self.max_subscriptions.release()
674674
return item
675675
except KeyError:
676-
await asyncio.sleep(0.001)
676+
await asyncio.sleep(0.1)
677677
return None
678678

679679

@@ -2151,14 +2151,14 @@ async def _make_rpc_request(
21512151
and current_time - self.ws.last_sent >= self.retry_timeout
21522152
):
21532153
if attempt >= self.max_retries:
2154-
logger.warning(
2154+
logger.error(
21552155
f"Timed out waiting for RPC requests {attempt} times. Exiting."
21562156
)
21572157
raise MaxRetriesExceeded("Max retries reached.")
21582158
else:
21592159
self.ws.last_received = time.time()
21602160
await self.ws.connect(force=True)
2161-
logger.error(
2161+
logger.warning(
21622162
f"Timed out waiting for RPC requests. "
21632163
f"Retrying attempt {attempt + 1} of {self.max_retries}"
21642164
)

0 commit comments

Comments
 (0)