|
|
@ -68,13 +68,13 @@ def compile_dir(dir, maxlevels=10, ddir=None, force=False, rx=None, |
|
|
optimize: optimization level or -1 for level of the interpreter |
|
|
optimize: optimization level or -1 for level of the interpreter |
|
|
workers: maximum number of parallel workers |
|
|
workers: maximum number of parallel workers |
|
|
""" |
|
|
""" |
|
|
|
|
|
if workers is not None and workers < 0: |
|
|
|
|
|
raise ValueError('workers must be greater or equal to 0') |
|
|
|
|
|
|
|
|
files = _walk_dir(dir, quiet=quiet, maxlevels=maxlevels, |
|
|
files = _walk_dir(dir, quiet=quiet, maxlevels=maxlevels, |
|
|
ddir=ddir) |
|
|
ddir=ddir) |
|
|
success = True |
|
|
success = True |
|
|
if workers is not None and workers != 1 and ProcessPoolExecutor is not None: |
|
|
if workers is not None and workers != 1 and ProcessPoolExecutor is not None: |
|
|
if workers < 0: |
|
|
|
|
|
raise ValueError('workers must be greater or equal to 0') |
|
|
|
|
|
|
|
|
|
|
|
workers = workers or None |
|
|
workers = workers or None |
|
|
with ProcessPoolExecutor(max_workers=workers) as executor: |
|
|
with ProcessPoolExecutor(max_workers=workers) as executor: |
|
|
results = executor.map(partial(compile_file, |
|
|
results = executor.map(partial(compile_file, |
|
|
|