ProcessPoolExecutor submit() doesn't work
There's a problem in the concurrent.futures.ProcessPoolExecutor.submit()
method.
Python 3.9.15 (21401ebc2df332b6be6e3d364a985e951a72bbbd, Dec 05 2022, 18:37:18)
[PyPy 7.3.10 with MSC v.1929 64 bit (AMD64)] on win32
values = process_map(self.count, candidates, max_workers=8, ncols=100, desc="Candidates", position=0)
File "C:\Program Files\PyPy\lib\site-packages\tqdm\contrib\concurrent.py", line 130, in process_map
return _executor_map(ProcessPoolExecutor, fn, *iterables, **tqdm_kwargs)
File "C:\Program Files\PyPy\lib\site-packages\tqdm\contrib\concurrent.py", line 76, in _executor_map
return list(tqdm_class(ex.map(fn, *iterables, **map_args), **kwargs))
File "C:\Program Files\PyPy\Lib\concurrent\futures\process.py", line 752, in map
results = super().map(partial(_process_chunk, fn),
File "C:\Program Files\PyPy\Lib\concurrent\futures\_base.py", line 598, in map
fs = [self.submit(fn, *args) for args in zip(*iterables)]
File "C:\Program Files\PyPy\Lib\concurrent\futures\_base.py", line 598, in <listcomp>
fs = [self.submit(fn, *args) for args in zip(*iterables)]
File "C:\Program Files\PyPy\Lib\concurrent\futures\process.py", line 723, in submit
self._adjust_process_count()
AttributeError: 'ProcessPoolExecutor' object has no attribute '_adjust_process_count'
The call to self._adjust_process_count()
should actually be self._adjust_process_count_cpython()