lambda: don't overrun number of workers needed

This commit is contained in:
James R. Barlow
2021-01-24 23:46:40 -08:00
parent 1a3ce59476
commit 6083b4f0a7
+2 -2
View File
@@ -141,10 +141,10 @@ def _lambda_pool_impl(
processes = []
connections = []
for n in range(max_workers):
for chunk in grouped_args:
parent_conn, child_conn = Pipe()
worker_args = [args for args in grouped_args[n] if args is not None]
worker_args = [args for args in chunk if args is not None]
process = Process(
target=process_loop,
args=(