8000
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.
concurrent/futures/process.py
1 parent a21b7e8 commit b3488e8Copy full SHA for b3488e8
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