Prevent race condition

Author: thewhaleking

async_substrate_interface/async_substrate.py

@@ -2512,6 +2512,7 @@ async def _make_rpc_request(
         subscription_added = False
 
         async with self.ws as ws:
+            await ws.mark_waiting_for_response()
             for payload in payloads:
                 item_id = await ws.send(payload["payload"])
                 request_manager.add_request(item_id, payload["id"])
@@ -2523,7 +2524,6 @@ async def _make_rpc_request(
                 logger.debug(
                     f"Submitted payload ID {payload['id']} with websocket ID {item_id}: {output_payload}"
                 )
-            await ws.mark_waiting_for_response()
 
             while True:
                 for item_id in request_manager.unresponded():