diff --git a/ipykernel/inprocess/socket.py b/ipykernel/inprocess/socket.py index ff826ea0c..477c36a47 100644 --- a/ipykernel/inprocess/socket.py +++ b/ipykernel/inprocess/socket.py @@ -31,7 +31,7 @@ def recv_multipart(self, flags=0, copy=True, track=False): return self.queue.get_nowait() def send_multipart(self, msg_parts, flags=0, copy=True, track=False): - msg_parts = list(map(zmq.Message, msg_parts)) # type:ignore[arg-type] + msg_parts = list(map(zmq.Message, msg_parts)) self.queue.put_nowait(msg_parts) self.message_sent += 1 diff --git a/ipykernel/iostream.py b/ipykernel/iostream.py index 3d66a7239..419d092c3 100644 --- a/ipykernel/iostream.py +++ b/ipykernel/iostream.py @@ -13,7 +13,7 @@ from binascii import b2a_hex from collections import deque from io import StringIO, TextIOBase -from typing import Any, Callable, Optional +from typing import Any, Callable, Deque, Optional from weakref import WeakSet import zmq @@ -67,7 +67,7 @@ def __init__(self, socket, pipe=False): if pipe: self._setup_pipe_in() self._local = threading.local() - self._events: deque[Callable[..., Any]] = deque() + self._events: Deque[Callable[..., Any]] = deque() self._event_pipes: WeakSet[Any] = WeakSet() self._setup_event_pipe() self.thread = threading.Thread(target=self._thread_main, name="IOPub") diff --git a/ipykernel/kernelbase.py b/ipykernel/kernelbase.py index 617729cf8..482688bed 100644 --- a/ipykernel/kernelbase.py +++ b/ipykernel/kernelbase.py @@ -1197,9 +1197,7 @@ def _input_request(self, prompt, ident, parent, password=False): # zmq.select() is also uninterruptible, but at least this # way reads get noticed immediately and KeyboardInterrupts # get noticed fairly quickly by human response time standards. - rlist, _, xlist = zmq.select( - [self.stdin_socket], [], [self.stdin_socket], 0.01 # type:ignore[arg-type] - ) + rlist, _, xlist = zmq.select([self.stdin_socket], [], [self.stdin_socket], 0.01) if rlist or xlist: ident, reply = self.session.recv(self.stdin_socket) if (ident, reply) != (None, None):