We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
concurrent/futures/process.py
1 parent a21b7e8 commit b3488e8Copy full SHA for b3488e8
1 file changed
Lib/concurrent/futures/process.py
@@ -49,7 +49,7 @@
49
from concurrent.futures import _base
50
import queue
51
import multiprocessing as mp
52
-import multiprocessing.connection
+import multiprocessing.connection as mp_connection
53
from multiprocessing.queues import Queue
54
import threading
55
import weakref
@@ -404,7 +404,7 @@ def wait_result_broken_or_wakeup(self):
404
wakeup_reader = self.thread_wakeup._reader
405
readers = [result_reader, wakeup_reader]
406
worker_sentinels = [p.sentinel for p in list(self.processes.values())]
407
- ready = mp.connection.wait(readers + worker_sentinels)
+ ready = mp_connection.wait(readers + worker_sentinels)
408
409
cause = None
410
is_broken = True
0 commit comments