We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dab3b39 commit dcdc56eCopy full SHA for dcdc56e
ipykernel/iostream.py
@@ -388,6 +388,9 @@ def _watch_pipe_fd(self):
388
389
"""
390
391
+ if self._fid is None:
392
+ return
393
+
394
try:
395
bts = os.read(self._fid, PIPE_BUFFER_SIZE)
396
while bts and self._should_watch:
@@ -441,6 +444,7 @@ def __init__(
441
444
self.session = session
442
445
self._has_thread = False
443
446
self.watch_fd_thread = None
447
+ self._fid = None
448
if not isinstance(pub_thread, IOPubThread):
449
# Backward-compat: given socket, not thread. Wrap in a thread.
450
warnings.warn(
0 commit comments