We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d7713f6 commit 51ae59fCopy full SHA for 51ae59f
ipyparallel/client/client.py
@@ -7,6 +7,7 @@
7
import os
8
import re
9
import socket
10
+import sys
11
import time
12
import types
13
import warnings
@@ -1078,6 +1079,13 @@ def _io_main(self, start_evt=None):
1078
1079
"""main loop for background IO thread"""
1080
self._io_loop = self._make_io_loop()
1081
self._setup_streams()
1082
+
1083
+ # disable ipykernel's association of thread output with the cell that
1084
+ # spawned the thread.
1085
+ # there should be a public API for this...
1086
+ for stream in [sys.stdout, sys.stderr]:
1087
+ if getattr(stream, "_thread_to_parent", None):
1088
+ stream._thread_to_parent.pop(current_thread().ident, None)
1089
# signal that start has finished
1090
# so that the main thread knows that all our attributes are defined
1091
if start_evt:
0 commit comments