pasteur.utils.progress.process_in_parallel

pasteur.utils.progress.process_in_parallel(fun, per_call_args, base_args=None, min_chunk_size=1, desc=None, max_worker_mult=1, initializer=None, finalizer=None)

Processes arguments in parallel using the common process pool and prints progress bar.

Implements a custom form of chunk iteration, where base_args contains arguments with large size that are common in all function calls and per_call_args which change every iteration.

Return type:

list[TypeVar(X)]