update more requests

ipykernel/ipkernel.py

@@ -497,7 +497,7 @@ async def run(execution: Execution) -> None:
 
         return reply_content
 
-    def do_complete(self, code, cursor_pos):
+    async def do_complete(self, code, cursor_pos):
         """Handle code completion."""
         if _use_experimental_60_completion and self.use_experimental_completions:
             return self._experimental_do_complete(code, cursor_pos)
@@ -567,7 +567,7 @@ def _experimental_do_complete(self, code, cursor_pos):
             "status": "ok",
         }
 
-    def do_inspect(self, code, cursor_pos, detail_level=0, omit_sections=()):
+    async def do_inspect(self, code, cursor_pos, detail_level=0, omit_sections=()):
         """Handle code inspection."""
         name = token_at_cursor(code, cursor_pos)
 
@@ -595,7 +595,7 @@ def do_inspect(self, code, cursor_pos, detail_level=0, omit_sections=()):
 
         return reply_content
 
-    def do_history(
+    async def do_history(
         self,
         hist_access_type,
         output,
@@ -631,13 +631,13 @@ def do_history(
             "history": list(hist),
         }
 
-    def do_shutdown(self, restart):
+    async def do_shutdown(self, restart):
         """Handle kernel shutdown."""
         if self.shell:
             self.shell.exit_now = True
         return dict(status="ok", restart=restart)
 
-    def do_is_complete(self, code):
+    async def do_is_complete(self, code):
         """Handle an is_complete request."""
         transformer_manager = getattr(self.shell, "input_transformer_manager", None)
         if transformer_manager is None:

tests/conftest.py

@@ -116,6 +116,7 @@ def destroy(self):
     @no_type_check
     async def test_shell_message(self, *args, **kwargs):
         msg_list = self._prep_msg(*args, **kwargs)
+        print(msg_list)
         await self.process_shell_message(msg_list)
         receive_stream: MemoryObjectReceiveStream[Any] = self.session._streams[self.shell_socket][
             "receive"