pyphi.parallel.backends.local_process

Process-pool scheduler backed by loky.

Uses loky (via joblib) instead of ProcessPoolExecutor for cloudpickle support, allowing functions defined in __main__ (e.g., Jupyter notebooks) to be serialized and sent to worker processes.

Also exports LocalProcessScheduler, the Protocol-conforming wrapper around LocalMapReduce that delivers a ConfigSnapshot to workers via closure.

Classes

LocalMapReduce(map_func, iterables, ...[, ...])	Single-machine parallelization using loky's reusable executor.
LocalProcessScheduler()	Scheduler backed by loky's reusable process executor.