[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

@@ -551,7 +551,9 @@ async def start(self, *, task_status: TaskStatus = TASK_STATUS_IGNORED) -> None:
                 # Assign tasks to and start shell channel thread.
                 manager = self.shell_channel_thread.manager
                 self.shell_channel_thread.add_task(self.shell_channel_thread_main)
-                self.shell_channel_thread.add_task(manager.listen_from_control, self.shell_main, self.shell_channel_thread)
+                self.shell_channel_thread.add_task(
+                    manager.listen_from_control, self.shell_main, self.shell_channel_thread
+                )
                 self.shell_channel_thread.add_task(manager.listen_from_subshells)
                 self.shell_channel_thread.start()
             else:
@@ -1081,7 +1083,9 @@ async def create_subshell_request(self, socket, ident, parent) -> None:
 
         # This should only be called in the control thread if it exists.
         # Request is passed to shell channel thread to process.
-        other_socket = await self.shell_channel_thread.manager.get_control_other_socket(self.control_thread.get_task_group())
+        other_socket = await self.shell_channel_thread.manager.get_control_other_socket(
+            self.control_thread.get_task_group()
+        )
         await other_socket.asend_json({"type": "create"})
         reply = await other_socket.arecv_json()
 
@@ -1103,7 +1107,9 @@ async def delete_subshell_request(self, socket, ident, parent) -> None:
 
         # This should only be called in the control thread if it exists.
         # Request is passed to shell channel thread to process.
-        other_socket = await self.shell_channel_thread.manager.get_control_other_socket(self.control_thread.get_task_group())
+        other_socket = await self.shell_channel_thread.manager.get_control_other_socket(
+            self.control_thread.get_task_group()
+        )
         await other_socket.asend_json({"type": "delete", "subshell_id": subshell_id})
         reply = await other_socket.arecv_json()
 
@@ -1118,7 +1124,9 @@ async def list_subshell_request(self, socket, ident, parent) -> None:
 
         # This should only be called in the control thread if it exists.
         # Request is passed to shell channel thread to process.
-        other_socket = await self.shell_channel_thread.manager.get_control_other_socket(self.control_thread.get_task_group())
+        other_socket = await self.shell_channel_thread.manager.get_control_other_socket(
+            self.control_thread.get_task_group()
+        )
         await other_socket.asend_json({"type": "list"})
         reply = await other_socket.arecv_json()
 

ipykernel/subshell_manager.py

@@ -40,7 +40,12 @@ class SubshellManager:
     against multiple subshells attempting to send at the same time.
     """
 
-    def __init__(self, context: zmq.Context, shell_socket: zmq_anyio.Socket, get_task_group: Callable[[], TaskGroup]):
+    def __init__(
+        self,
+        context: zmq.Context,
+        shell_socket: zmq_anyio.Socket,
+        get_task_group: Callable[[], TaskGroup],
+    ):
         assert current_thread() == main_thread()
 
         self._context: zmq.Context = context
@@ -229,7 +234,9 @@ def _is_subshell(self, subshell_id: str | None) -> bool:
         with self._lock_cache:
             return subshell_id in self._cache
 
-    async def _listen_for_subshell_reply(self, subshell_id: str | None, task_group: TaskGroup) -> None:
+    async def _listen_for_subshell_reply(
+        self, subshell_id: str | None, task_group: TaskGroup
+    ) -> None:
         """Listen for reply messages on specified subshell inproc socket and
         resend to the client via the shell_socket.
 

tests/conftest.py

@@ -22,10 +22,11 @@
     resource = None  # type:ignore
 
 
-@pytest.fixture
+@pytest.fixture()
 def anyio_backend():
     return "asyncio"
 
+
 pytestmark = pytest.mark.anyio