@@ -30,7 +30,7 @@ async def shutdown_request(self, stream, ident, parent):
3030 if os .environ .get ("NO_SHUTDOWN_REPLY" ) != "1" :
3131 await super ().shutdown_request (stream , ident , parent )
3232
33- async def do_execute (
33+ def do_execute (
3434 self , code , silent , store_history = True , user_expressions = None , allow_stdin = False
3535 ):
3636 code = code .strip ()
@@ -47,31 +47,12 @@ async def do_execute(
4747 elif code == "env" :
4848 reply ["user_expressions" ]["env" ] = os .getenv ("TEST_VARS" , "" )
4949 elif code == "sleep" :
50- import ipykernel
51-
52- if ipykernel .version_info < (7 , 0 ):
53- # ipykernel before anyio.
54- try :
55- time .sleep (10 )
56- except KeyboardInterrupt :
57- reply ["user_expressions" ]["interrupted" ] = True
58- else :
59- reply ["user_expressions" ]["interrupted" ] = False
50+ try :
51+ time .sleep (10 )
52+ except KeyboardInterrupt :
53+ reply ["user_expressions" ]["interrupted" ] = True
6054 else :
61- # ipykernel after anyio.
62- from anyio import create_task_group , open_signal_receiver , sleep
63-
64- async def signal_handler (cancel_scope , reply ):
65- with open_signal_receiver (signal .SIGINT ) as signals :
66- async for _ in signals :
67- reply ["user_expressions" ]["interrupted" ] = True
68- cancel_scope .cancel ()
69- return
70-
7155 reply ["user_expressions" ]["interrupted" ] = False
72- async with create_task_group () as tg :
73- tg .start_soon (signal_handler , tg .cancel_scope , reply )
74- tg .start_soon (sleep , 10 )
7556 else :
7657 reply ["status" ] = "error"
7758 reply ["ename" ] = "Error"
0 commit comments