File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 66from anyio .abc import CancelScope
77
88from .base_server import BaseServer
9+ from .file_server import FileServer
910
1011
1112async def signal_handler (scope : CancelScope ):
@@ -22,9 +23,12 @@ async def signal_handler(scope: CancelScope):
2223
2324def run (server : BaseServer ):
2425 async def main ():
25- async with anyio .create_task_group () as tg :
26- tg .start_soon (signal_handler , tg .cancel_scope )
27- tg .start_soon (server .run )
26+ if isinstance (server , FileServer ):
27+ await server .run ()
28+ else :
29+ async with anyio .create_task_group () as tg :
30+ tg .start_soon (signal_handler , tg .cancel_scope )
31+ tg .start_soon (server .run )
2832
2933 anyio .run (main )
3034
@@ -38,7 +42,7 @@ async def main():
3842
3943
4044def create_server ():
41- io = os .environ .get ("EVAL_IO" , "rpc" )
45+ io = os .environ .get ("EVAL_IO" , "rpc" ). lower ()
4246
4347 if io == "rpc" :
4448 return create_rpc_server ()
You can’t perform that action at this time.
0 commit comments