[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

ipykernel/debugger.py

@@ -17,10 +17,10 @@
 except ImportError:
     from jupyter_client.jsonutil import date_default as json_default
 
-from .compiler import get_file_name, get_tmp_directory, get_tmp_hash_seed
-
 import threading
 
+from .compiler import get_file_name, get_tmp_directory, get_tmp_hash_seed
+
 try:
     # This import is required to have the next ones working...
     from debugpy.server import api  # noqa: F401

ipykernel/displayhook.py

@@ -6,6 +6,7 @@
 
 import builtins
 import sys
+import threading
 import typing as t
 
 from IPython.core.displayhook import DisplayHook
@@ -15,9 +16,6 @@
 from ipykernel.jsonutil import encode_images, json_clean
 
 
-import threading
-
-
 class ZMQDisplayHook:
     """A simple displayhook that publishes the object's repr over a ZeroMQ
     socket."""
@@ -104,7 +102,6 @@ def finish_displayhook(self):
         sys.stdout.flush()
         sys.stderr.flush()
         if self.msg and self.msg["content"]["data"] and self.session:
-
             with open("debug.txt", "a") as f:
                 f.write(f"{threading.current_thread().ident} pub_socket ?finish_displayhook\n")
 

ipykernel/iostream.py

@@ -79,7 +79,7 @@ def __init__(self, socket, pipe=False):
         self.thread.name = "IOPub"
 
         with open("debug.txt", "a") as f:
-            f.write(f"    IOPubThread.__init__\n")
+            f.write("    IOPubThread.__init__\n")
 
     def _thread_main(self):
         """The inner loop that's actually run in a thread"""

ipykernel/kernelbase.py

@@ -79,6 +79,7 @@ def _accepts_parameters(meth, param_names):
 
 class Kernel(SingletonConfigurable):
     """The base kernel class."""
+
     # ---------------------------------------------------------------------------
     # Kernel interface
     # ---------------------------------------------------------------------------
@@ -276,12 +277,8 @@ def __init__(self, **kwargs):
         """Initialize the kernel."""
         super().__init__(**kwargs)
 
-
-
         self._iant_lock = threading.Lock()
 
-
-
         # Kernel application may swap stdout and stderr to OutStream,
         # which is the case in `IPKernelApp.init_io`, hence `sys.stdout`
         # can already by different from TextIO at initialization time.
@@ -619,7 +616,9 @@ async def shell_channel_thread_main(self, msg):
             subshell_id = msg3["header"].get("subshell_id")
 
             with open("debug.txt", "a") as f:
-                f.write(f"{threading.current_thread().ident} shell_channel_thread_main msg received for {subshell_id}\n")
+                f.write(
+                    f"{threading.current_thread().ident} shell_channel_thread_main msg received for {subshell_id}\n"
+                )
 
             # Find inproc pair socket to use to send message to correct subshell.
             subshell_manager = self.shell_channel_thread.manager
@@ -684,7 +683,6 @@ def _publish_execute_input(self, code, parent, execution_count):
         if not self.session:
             return
         with self._iant_lock:
-
             with open("debug.txt", "a") as f:
                 f.write(f"{threading.current_thread().ident} iopub_socket execute_input\n")
 
@@ -701,7 +699,6 @@ def _publish_status(self, status, channel, parent=None):
         if not self.session:
             return
         with self._iant_lock:
-
             with open("debug.txt", "a") as f:
                 f.write(f"{threading.current_thread().ident} iopub_socket status {status}\n")
 
@@ -723,7 +720,6 @@ def _publish_debug_event(self, event):
         if not self.session:
             return
         with self._iant_lock:
-
             with open("debug.txt", "a") as f:
                 f.write(f"{threading.current_thread().ident} iopub_socket debug_event\n")
 
@@ -870,12 +866,13 @@ async def execute_request(self, stream, ident, parent):
         if self._do_exec_accepted_params["cell_id"]:
             do_execute_args["cell_id"] = cell_id
 
-
         subshell_id = parent["header"].get("subshell_id")
         msg_id = parent["header"].get("msg_id")
 
         with open("debug.txt", "a") as f:
-            f.write(f"{threading.current_thread().ident} about to execute_request {msg_id} {subshell_id} {code}\n")
+            f.write(
+                f"{threading.current_thread().ident} about to execute_request {msg_id} {subshell_id} {code}\n"
+            )
 
         # Call do_execute with the appropriate arguments
         reply_content = self.do_execute(**do_execute_args)
@@ -897,7 +894,9 @@ async def execute_request(self, stream, ident, parent):
         metadata = self.finish_metadata(parent, metadata, reply_content)
 
         with open("debug.txt", "a") as f:
-            f.write(f"{threading.current_thread().ident} execute_reply            {msg_id} {subshell_id}\n")
+            f.write(
+                f"{threading.current_thread().ident} execute_reply            {msg_id} {subshell_id}\n"
+            )
 
         reply_msg: dict[str, t.Any] = self.session.send(  # type:ignore[assignment]
             stream,
@@ -1643,7 +1642,6 @@ async def _at_shutdown(self):
         finally:
             if self._shutdown_message is not None and self.session:
                 with self._iant_lock:
-
                     with open("debug.txt", "a") as f:
                         f.write(f"{threading.current_thread().ident} ? _shutdown\n")
 

tests/utils.py

@@ -172,15 +172,19 @@ def new_kernel(argv=None):
     return manager.run_kernel(**kwargs)
 
 
-def assemble_output(get_msg, timeout=1, parent_msg_id: str | None=None):
+def assemble_output(get_msg, timeout=1, parent_msg_id: str | None = None):
     """assemble stdout/err from an execution"""
     stdout = ""
     stderr = ""
     while True:
         msg = get_msg(timeout=timeout)
         msg_type = msg["msg_type"]
         content = msg["content"]
-        if msg_type == "status" and content["execution_state"] == "idle" and (parent_msg_id is None or msg["parent_header"]["msg_id"] == parent_msg_id):
+        if (
+            msg_type == "status"
+            and content["execution_state"] == "idle"
+            and (parent_msg_id is None or msg["parent_header"]["msg_id"] == parent_msg_id)
+        ):
             # idle message signals end of output
             break
         elif msg["msg_type"] == "stream":
@@ -196,12 +200,16 @@ def assemble_output(get_msg, timeout=1, parent_msg_id: str | None=None):
     return stdout, stderr
 
 
-def wait_for_idle(kc, parent_msg_id: str | None=None):
+def wait_for_idle(kc, parent_msg_id: str | None = None):
     while True:
         msg = kc.get_iopub_msg(timeout=1)
         msg_type = msg["msg_type"]
         content = msg["content"]
-        if msg_type == "status" and content["execution_state"] == "idle" and (parent_msg_id is None or msg['parent_header']['msg_id'] == parent_msg_id):
+        if (
+            msg_type == "status"
+            and content["execution_state"] == "idle"
+            and (parent_msg_id is None or msg["parent_header"]["msg_id"] == parent_msg_id)
+        ):
             break