@@ -222,7 +222,7 @@ def get_free_port():
222222 print (f"Testing using server on port { port } " )
223223 proxy = ProxyServer ("wss://archive.sub.latent.to" , 10 , 20 , port = port )
224224
225- server_thread = threading .Thread (target = proxy .connect_and_serve , daemon = True )
225+ server_thread = threading .Thread (target = proxy .connect_and_serve )
226226 server_thread .start ()
227227 await asyncio .sleep (3 ) # give the server start up time
228228 async with AsyncSubstrateInterface (
@@ -259,7 +259,7 @@ def get_free_port():
259259 shutdown_thread = threading .Thread (target = proxy .close )
260260 shutdown_thread .start ()
261261 shutdown_thread .join (timeout = 5 )
262- # server_thread.join(timeout=5)
262+ server_thread .join (timeout = 5 )
263263 print ("test_improved_reconnection succeeded" )
264264
265265
@@ -314,10 +314,10 @@ async def test_concurrent_rpc_requests():
314314 """
315315 print ("Testing test_concurrent_rpc_requests" )
316316
317- async def concurrent_task (substrate , task_id ):
317+ async def concurrent_task (substrate_ , task_id ):
318318 """Make multiple RPC calls from a single task."""
319319 for i in range (5 ):
320- result = await substrate .get_block_number (None )
320+ result = await substrate_ .get_block_number (None )
321321 assert isinstance (result , int )
322322 assert result > 0
323323
0 commit comments