ruff-check unsafe-fixes

Author: Carreau

ipykernel/debugger.py

@@ -429,7 +429,7 @@ def start(self):
                 (self.shell_socket.getsockopt(ROUTING_ID)),
             )
 
-            ident, msg = self.session.recv(self.shell_socket, mode=0)
+            _ident, msg = self.session.recv(self.shell_socket, mode=0)
             self.debugpy_initialized = msg["content"]["status"] == "ok"
 
         # Don't remove leading empty lines when debugging so the breakpoints are correctly positioned

ipykernel/inprocess/client.py

@@ -206,7 +206,7 @@ def _dispatch_to_kernel(self, msg):
         else:
             loop = asyncio.get_event_loop()  # type:ignore[unreachable]
             loop.run_until_complete(kernel.dispatch_shell(msg_parts))
-        idents, reply_msg = self.session.recv(stream, copy=False)
+        _idents, reply_msg = self.session.recv(stream, copy=False)
         self.shell_channel.call_handlers_later(reply_msg)
 
     def get_shell_msg(self, block=True, timeout=None):

ipykernel/inprocess/ipkernel.py

@@ -135,7 +135,7 @@ def _io_dispatch(self, change):
         """Called when a message is sent to the IO socket."""
         assert self.iopub_socket.io_thread is not None
         assert self.session is not None
-        ident, msg = self.session.recv(self.iopub_socket.io_thread.socket, copy=False)
+        _ident, msg = self.session.recv(self.iopub_socket.io_thread.socket, copy=False)
         for frontend in self.frontends:
             assert frontend is not None
             frontend.iopub_channel.call_handlers(msg)

tests/inprocess/test_kernel.py

@@ -57,7 +57,7 @@ def test_pylab(kc):
     """Does %pylab work in the in-process kernel?"""
     _ = pytest.importorskip("matplotlib", reason="This test requires matplotlib")
     kc.execute("%pylab")
-    out, err = assemble_output(kc.get_iopub_msg)
+    out, _err = assemble_output(kc.get_iopub_msg)
     assert "matplotlib" in out
 
 
@@ -85,7 +85,7 @@ def test_stdout(kc):
     kc = BlockingInProcessKernelClient(kernel=kernel, session=kernel.session)
     kernel.frontends.append(kc)
     kc.execute('print("bar")')
-    out, err = assemble_output(kc.get_iopub_msg)
+    out, _err = assemble_output(kc.get_iopub_msg)
     assert out == "bar\n"
 
 
@@ -102,7 +102,7 @@ def test_capfd(kc):
     kernel.frontends.append(kc)
     kc.execute("import os")
     kc.execute('os.system("echo capfd")')
-    out, err = assemble_output(kc.iopub_channel)
+    out, _err = assemble_output(kc.iopub_channel)
     assert out == "capfd\n"
 
 

tests/test_async.py

@@ -23,7 +23,7 @@ def _setup_env():
 
 def test_async_await():
     flush_channels(KC)
-    msg_id, content = execute("import asyncio; await asyncio.sleep(0.1)", KC)
+    _msg_id, content = execute("import asyncio; await asyncio.sleep(0.1)", KC)
     assert content["status"] == "ok", content
 
 

tests/test_embed_kernel.py

@@ -64,7 +64,7 @@ def connection_file_ready(connection_file):
         time.sleep(0.1)
 
         if kernel.poll() is not None:
-            o, e = kernel.communicate()
+            _o, e = kernel.communicate()
             raise OSError("Kernel failed to start:\n%s" % e)
 
         if not os.path.exists(connection_file):

tests/test_io.py

@@ -222,7 +222,7 @@ def test_echo_watch(ctx):
         print(f"{p.stderr}=", file=sys.stderr)
         assert p.returncode == 0
         while s.poll(timeout=100):
-            ident, msg = session.recv(s)
+            _ident, msg = session.recv(s)
             assert msg is not None  # for type narrowing
             if msg["header"]["msg_type"] == "stream" and msg["content"]["name"] == "stdout":
                 stdout_chunks.append(msg["content"]["text"])

tests/test_kernel.py

@@ -34,8 +34,8 @@
 def _check_master(kc, expected=True, stream="stdout"):
     execute(kc=kc, code="import sys")
     flush_channels(kc)
-    msg_id, content = execute(kc=kc, code="print(sys.%s._is_master_process())" % stream)
-    stdout, stderr = assemble_output(kc.get_iopub_msg)
+    _msg_id, _content = execute(kc=kc, code="print(sys.%s._is_master_process())" % stream)
+    stdout, _stderr = assemble_output(kc.get_iopub_msg)
     assert stdout.strip() == repr(expected)
 
 
@@ -51,7 +51,7 @@ def _check_status(content):
 def test_simple_print():
     """simple print statement in kernel"""
     with kernel() as kc:
-        msg_id, content = execute(kc=kc, code="print('hi')")
+        _msg_id, _content = execute(kc=kc, code="print('hi')")
         stdout, stderr = assemble_output(kc.get_iopub_msg)
         assert stdout == "hi\n"
         assert stderr == ""
@@ -251,7 +251,7 @@ def test_capture_fd():
     """simple print statement in kernel"""
     with kernel() as kc:
         iopub = kc.iopub_channel
-        msg_id, content = execute(kc=kc, code="import os; os.system('echo capsys')")
+        _msg_id, _content = execute(kc=kc, code="import os; os.system('echo capsys')")
         stdout, stderr = assemble_output(iopub)
         assert stdout == "capsys\n"
         assert stderr == ""
@@ -262,7 +262,7 @@ def test_capture_fd():
 def test_subprocess_peek_at_stream_fileno():
     with kernel() as kc:
         iopub = kc.iopub_channel
-        msg_id, content = execute(
+        _msg_id, _content = execute(
             kc=kc,
             code="import subprocess, sys; subprocess.run(['python', '-c', 'import os; os.system(\"echo CAP1\"); print(\"CAP2\")'], stderr=sys.stderr)",
         )
@@ -275,7 +275,7 @@ def test_subprocess_peek_at_stream_fileno():
 def test_sys_path():
     """test that sys.path doesn't get messed up by default"""
     with kernel() as kc:
-        msg_id, content = execute(kc=kc, code="import sys; print(repr(sys.path))")
+        _msg_id, _content = execute(kc=kc, code="import sys; print(repr(sys.path))")
         stdout, stderr = assemble_output(kc.get_iopub_msg)
     # for error-output on failure
     sys.stderr.write(stderr)
@@ -288,7 +288,7 @@ def test_sys_path_profile_dir():
     """test that sys.path doesn't get messed up when `--profile-dir` is specified"""
 
     with new_kernel(["--profile-dir", locate_profile("default")]) as kc:
-        msg_id, content = execute(kc=kc, code="import sys; print(repr(sys.path))")
+        _msg_id, _content = execute(kc=kc, code="import sys; print(repr(sys.path))")
         stdout, stderr = assemble_output(kc.get_iopub_msg)
     # for error-output on failure
     sys.stderr.write(stderr)
@@ -323,7 +323,7 @@ def test_subprocess_print():
             ]
         )
 
-        msg_id, content = execute(kc=kc, code=code)
+        _msg_id, _content = execute(kc=kc, code=code)
         stdout, stderr = assemble_output(kc.get_iopub_msg)
         assert stdout.count("hello") == np, stdout
         for n in range(np):
@@ -347,7 +347,7 @@ def test_subprocess_noprint():
             ]
         )
 
-        msg_id, content = execute(kc=kc, code=code)
+        _msg_id, _content = execute(kc=kc, code=code)
         stdout, stderr = assemble_output(kc.get_iopub_msg)
         assert stdout == ""
         assert stderr == ""
@@ -373,7 +373,7 @@ def test_subprocess_error():
             ]
         )
 
-        msg_id, content = execute(kc=kc, code=code)
+        _msg_id, _content = execute(kc=kc, code=code)
         stdout, stderr = assemble_output(kc.get_iopub_msg)
         assert stdout == ""
         assert "ValueError" in stderr
@@ -400,7 +400,7 @@ def test_raw_input():
         kc.input(text)
         reply = kc.get_shell_msg(timeout=TIMEOUT)
         assert reply["content"]["status"] == "ok"
-        stdout, stderr = assemble_output(kc.get_iopub_msg)
+        stdout, _stderr = assemble_output(kc.get_iopub_msg)
         assert stdout == text + "\n"
 
 
@@ -555,7 +555,7 @@ def test_unc_paths():
         kc.execute(code="ls")
         reply = kc.get_shell_msg(timeout=TIMEOUT)
         assert reply["content"]["status"] == "ok"
-        out, err = assemble_output(kc.get_iopub_msg)
+        out, _err = assemble_output(kc.get_iopub_msg)
         assert "unc.txt" in out
 
         kc.execute(code="cd")
@@ -774,7 +774,7 @@ def test_shutdown_subprocesses():
     """Kernel exits after polite shutdown_request"""
     with new_kernel() as kc:
         km = kc.parent
-        msg_id, reply = execute(
+        _msg_id, reply = execute(
             f"from {__name__} import _start_children\n_start_children()",
             kc=kc,
             user_expressions={

tests/test_message_spec.py

@@ -426,7 +426,7 @@ def test_non_execute_stop_on_error():
 def test_user_expressions():
     flush_channels()
 
-    msg_id, reply = execute(code="x=1", user_expressions=dict(foo="x+1"))
+    _msg_id, reply = execute(code="x=1", user_expressions=dict(foo="x+1"))
     user_expressions = reply["user_expressions"]
     assert user_expressions == {
         "foo": {
@@ -440,7 +440,7 @@ def test_user_expressions():
 def test_user_expressions_fail():
     flush_channels()
 
-    msg_id, reply = execute(code="x=0", user_expressions=dict(foo="nosuchname"))
+    _msg_id, reply = execute(code="x=0", user_expressions=dict(foo="nosuchname"))
     user_expressions = reply["user_expressions"]
     foo = user_expressions["foo"]
     assert foo["status"] == "error"
@@ -572,7 +572,7 @@ def test_single_payload():
     transform) should avoid setting multiple set_next_input).
     """
     flush_channels()
-    msg_id, reply = execute(
+    _msg_id, reply = execute(
         code="ip = get_ipython()\nfor i in range(3):\n   ip.set_next_input('Hello There')\n"
     )
     payload = reply["payload"]
@@ -635,7 +635,7 @@ def test_history_search():
 def test_stream():
     flush_channels()
 
-    msg_id, reply = execute("print('hi')")
+    msg_id, _reply = execute("print('hi')")
 
     stdout = KC.get_iopub_msg(timeout=TIMEOUT)
     validate_message(stdout, "stream", msg_id)
@@ -646,7 +646,7 @@ def test_stream():
 def test_display_data():
     flush_channels()
 
-    msg_id, reply = execute("from IPython.display import display; display(1)")
+    msg_id, _reply = execute("from IPython.display import display; display(1)")
 
     display = KC.get_iopub_msg(timeout=TIMEOUT)
     validate_message(display, "display_data", parent=msg_id)