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

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

Author: pre-commit-ci[bot]

ipykernel/kernelbase.py

@@ -277,7 +277,7 @@ def __init__(self, **kwargs):
         """Initialize the kernel."""
         super().__init__(**kwargs)
 
-        #self._iant_lock = threading.Lock()
+        # 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`
@@ -682,7 +682,7 @@ def _publish_execute_input(self, code, parent, execution_count):
         """Publish the code request on the iopub stream."""
         if not self.session:
             return
-        #with self._iant_lock:
+        # with self._iant_lock:
         with open("debug.txt", "a") as f:
             f.write(f"{threading.current_thread().ident} iopub_socket execute_input\n")
 
@@ -698,7 +698,7 @@ def _publish_status(self, status, channel, parent=None):
         """send status (busy/idle) on IOPub"""
         if not self.session:
             return
-        #with self._iant_lock:
+        # with self._iant_lock:
         with open("debug.txt", "a") as f:
             f.write(f"{threading.current_thread().ident} iopub_socket status {status}\n")
 
@@ -719,7 +719,7 @@ def _publish_status_and_flush(self, status, channel, stream, parent=None):
     def _publish_debug_event(self, event):
         if not self.session:
             return
-        #with self._iant_lock:
+        # with self._iant_lock:
         with open("debug.txt", "a") as f:
             f.write(f"{threading.current_thread().ident} iopub_socket debug_event\n")
 
@@ -1234,11 +1234,9 @@ async def create_subshell_request(self, socket, ident, parent) -> None:
             self.log.error("Subshells are not supported by this kernel")
             return
 
-
         with open("debug.txt", "a") as f:
             f.write(f"{threading.current_thread().ident} ? create_subshell_request\n")
 
-
         assert threading.current_thread().name == CONTROL_THREAD_NAME
 
         # This should only be called in the control thread if it exists.
@@ -1646,7 +1644,7 @@ async def _at_shutdown(self):
 
         finally:
             if self._shutdown_message is not None and self.session:
-                #with self._iant_lock:
+                # with self._iant_lock:
                 with open("debug.txt", "a") as f:
                     f.write(f"{threading.current_thread().ident} ? _shutdown\n")
 

tests/test_subshells.py

@@ -20,7 +20,7 @@ def create_subshell_helper(kc: BlockingKernelClient):
     kc.control_channel.send(msg)
     msg_id = msg["header"]["msg_id"]
     reply = get_reply(kc, msg_id, TIMEOUT, channel="control")
-    #wait_for_idle(kc, msg_id)
+    # wait_for_idle(kc, msg_id)
     return reply["content"]
 
 
@@ -29,7 +29,7 @@ def delete_subshell_helper(kc: BlockingKernelClient, subshell_id: str):
     kc.control_channel.send(msg)
     msg_id = msg["header"]["msg_id"]
     reply = get_reply(kc, msg_id, TIMEOUT, channel="control")
-    #wait_for_idle(kc, msg_id)
+    # wait_for_idle(kc, msg_id)
     return reply["content"]
 
 
@@ -38,7 +38,7 @@ def list_subshell_helper(kc: BlockingKernelClient):
     kc.control_channel.send(msg)
     msg_id = msg["header"]["msg_id"]
     reply = get_reply(kc, msg_id, TIMEOUT, channel="control")
-    #wait_for_idle(kc, msg_id)
+    # wait_for_idle(kc, msg_id)
     return reply["content"]
 
 
@@ -52,7 +52,6 @@ def execute_request(kc: BlockingKernelClient, code: str, subshell_id: str | None
 def execute_request_subshell_id(
     kc: BlockingKernelClient, code: str, subshell_id: str | None, terminator: str = "\n"
 ):
-
     with open("debug.txt", "a") as f:
         f.write("CHECK 1\n")
 
@@ -126,7 +125,7 @@ def test_thread_ids():
         thread_id, main_thread_id = execute_thread_ids(kc)
         assert thread_id == main_thread_id
 
-        thread_id, main_thread_id = execute_thread_ids(kc, subshell_id)   # This is the problem
+        thread_id, main_thread_id = execute_thread_ids(kc, subshell_id)  # This is the problem
         assert thread_id != main_thread_id
 
         delete_subshell_helper(kc, subshell_id)

tests/utils.py

@@ -178,7 +178,7 @@ def assemble_output(get_msg, timeout=1, parent_msg_id: str | None = None):
     stderr = ""
     while True:
         msg = get_msg(timeout=timeout)
-        #with open("debug.txt", "a") as f:
+        # with open("debug.txt", "a") as f:
         #    f.write(f"assembly output {msg}\n")
         msg_type = msg["msg_type"]
         content = msg["content"]