(lint cleanup) This import causes an argument parameter to shadow the global import name.
import queue
from queue import Full
import multiprocessing as mp
-from multiprocessing.connection import wait
+import multiprocessing.connection
from multiprocessing.queues import Queue
import threading
import weakref
# submitted, from the executor being shutdown/gc-ed, or from the
# shutdown of the python interpreter.
worker_sentinels = [p.sentinel for p in processes.values()]
- ready = wait(readers + worker_sentinels)
+ ready = mp.connection.wait(readers + worker_sentinels)
cause = None
is_broken = True