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 63deaa5 commit f7bda5cCopy full SHA for f7bda5c
Lib/concurrent/futures/process.py
@@ -51,7 +51,7 @@
51
import queue
52
from queue import Full
53
import multiprocessing as mp
54
-from multiprocessing.connection import wait
+import multiprocessing.connection
55
from multiprocessing.queues import Queue
56
import threading
57
import weakref
@@ -352,7 +352,7 @@ def shutdown_worker():
352
# submitted, from the executor being shutdown/gc-ed, or from the
353
# shutdown of the python interpreter.
354
worker_sentinels = [p.sentinel for p in processes.values()]
355
- ready = wait(readers + worker_sentinels)
+ ready = mp.connection.wait(readers + worker_sentinels)
356
357
cause = None
358
is_broken = True
0 commit comments