File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -67,8 +67,8 @@ async def start(self):
6767 # Wait for either a new block OR a shutdown signal, whichever comes first.
6868 done , _ = await asyncio .wait (
6969 [
70- self .subtensor .wait_for_block (),
71- self .should_exit .wait (),
70+ asyncio . create_task ( self .subtensor .wait_for_block () ),
71+ asyncio . create_task ( self .should_exit .wait () ),
7272 ],
7373 timeout = 24 ,
7474 return_when = asyncio .FIRST_COMPLETED ,
Original file line number Diff line number Diff line change @@ -281,8 +281,8 @@ async def _main_loop(self):
281281 # Wait for either a new block OR a shutdown signal, whichever comes first.
282282 done , _ = await asyncio .wait (
283283 [
284- self .subtensor .wait_for_block (),
285- self .should_exit .wait (),
284+ asyncio . create_task ( self .subtensor .wait_for_block () ),
285+ asyncio . create_task ( self .should_exit .wait () ),
286286 ],
287287 timeout = 24 ,
288288 return_when = asyncio .FIRST_COMPLETED ,
You can’t perform that action at this time.
0 commit comments