Limit number of workers, in order to avoid 'too many open files' on machines with many processing units (format so that Black is happy)
@@ -1583,7 +1583,9 @@ def main(args=None):
pass
# Use up to cpu_count*2 workers because some tasks are I/O bound,
# but limit the number of worker to avoid too many open files.
- parallel = concurrent.futures.ProcessPoolExecutor(max_workers=min(cpu_count * 2, 256))
+ parallel = concurrent.futures.ProcessPoolExecutor(
+ max_workers=min(cpu_count * 2, 256)
+ )
name = options.output_name
outputPath = options.outputPath
