Skip to content

Commit 694aa11

Browse files
committed
Maybe better non-polling
1 parent 61f3a40 commit 694aa11

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

async_substrate_interface/async_substrate.py

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -974,11 +974,13 @@ async def retrieve(self, item_id: str) -> Optional[dict]:
974974
"""
975975
item: Optional[asyncio.Future] = self._received.get(item_id)
976976
if item is not None:
977-
if item.done():
978-
self.max_subscriptions.release()
979-
res = item.result()
980-
del self._received[item_id]
981-
return res
977+
# For regular requests, await the Future directly instead of polling
978+
if not item.done():
979+
await item
980+
self.max_subscriptions.release()
981+
res = item.result()
982+
del self._received[item_id]
983+
return res
982984
else:
983985
try:
984986
subscription = self._received_subscriptions[item_id].get_nowait()

0 commit comments

Comments
 (0)