@@ -862,7 +862,7 @@ async def execute_request(self, stream, ident, parent):
862862 subshell_id = parent ["header" ].get ("subshell_id" )
863863 self ._abort_queues (subshell_id )
864864
865- def do_execute (
865+ async def do_execute (
866866 self ,
867867 code ,
868868 silent ,
@@ -897,7 +897,7 @@ async def complete_request(self, stream, ident, parent):
897897 matches = json_clean (matches )
898898 self .session .send (stream , "complete_reply" , matches , parent , ident )
899899
900- def do_complete (self , code , cursor_pos ):
900+ async def do_complete (self , code , cursor_pos ):
901901 """Override in subclasses to find completions."""
902902 return {
903903 "matches" : [],
@@ -933,7 +933,7 @@ async def inspect_request(self, stream, ident, parent):
933933 msg = self .session .send (stream , "inspect_reply" , reply_content , parent , ident )
934934 self .log .debug ("%s" , msg )
935935
936- def do_inspect (self , code , cursor_pos , detail_level = 0 , omit_sections = ()):
936+ async def do_inspect (self , code , cursor_pos , detail_level = 0 , omit_sections = ()):
937937 """Override in subclasses to allow introspection."""
938938 return {"status" : "ok" , "data" : {}, "metadata" : {}, "found" : False }
939939
@@ -957,7 +957,7 @@ async def history_request(self, stream, ident, parent):
957957 msg = self .session .send (stream , "history_reply" , reply_content , parent , ident )
958958 self .log .debug ("%s" , msg )
959959
960- def do_history (
960+ async def do_history (
961961 self ,
962962 hist_access_type ,
963963 output ,
@@ -1097,7 +1097,7 @@ async def shutdown_request(self, stream, ident, parent):
10971097 shell_io_loop = self .shell_stream .io_loop
10981098 shell_io_loop .add_callback (shell_io_loop .stop )
10991099
1100- def do_shutdown (self , restart ):
1100+ async def do_shutdown (self , restart ):
11011101 """Override in subclasses to do things when the frontend shuts down the
11021102 kernel.
11031103 """
@@ -1123,7 +1123,7 @@ async def is_complete_request(self, stream, ident, parent):
11231123 reply_msg = self .session .send (stream , "is_complete_reply" , reply_content , parent , ident )
11241124 self .log .debug ("%s" , reply_msg )
11251125
1126- def do_is_complete (self , code ):
1126+ async def do_is_complete (self , code ):
11271127 """Override in subclasses to find completions."""
11281128 return {"status" : "unknown" }
11291129
0 commit comments