local

Classes

LocalRunner()	LocalRunner for one threaded run.
ParallelLocalRunner([n_jobs, backend, ...])	ParallelLocalRunner for multiple parallel runs with joblib.

class LocalRunner

LocalRunner for one threaded run.

class ParallelLocalRunner(n_jobs: int = 1, backend: str = 'multiprocessing', mmap_mode: str = 'c', joblib_params: Optional[dict] = None)

ParallelLocalRunner for multiple parallel runs with joblib.

Notes

Global objects behavior could be different while parallel usage because platform dependent new process start. Be sure that new process is started with fork via multiprocessing.set_start_method. If it’s not possible you should try define all globals before if __name__ == "__main__" scope.

Warning

This class uses dill module during serialization which might be not secure.

Init ParallelLocalRunner.

Parameters

• n_jobs (int) – number of parallel jobs to use

• backend (str) – joblib backend to use

• mmap_mode (str) – joblib mmap mode

• joblib_params (Optional[dict]) – joblib additional params