andras/great-ai
andras/great-ai
Watch
1
0
Fork
You've already forked great-ai
 0
Code Issues Pull requests 2 Projects Releases 4 Packages 1 Wiki Activity Actions

Minor fixes

Browse source
This commit is contained in:
Andras Schmelczer 2022-07-02 21:57:09 +02:00
commit b89556cc39
No known key found for this signature in database
GPG key ID: 0EA1BC97D0AB076E
1 changed files with 9 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/great_ai/utilities/parallel_map/threaded_parallel_map.py
View file

@ -86,8 +86,8 @@ def threaded_parallel_map(
ignore_exceptions=ignore_exceptions,
)
input_queue = queue.Queue(0 if config.chunk_count is None else config.chunk_count)
output_queue = queue.Queue(0 if config.chunk_count is None else config.chunk_count)
input_queue = queue.Queue(config.concurrency * 2)
output_queue = queue.Queue(config.concurrency * 2)
should_stop = threading.Event()
threads = [