rex.utilities.execution

Execution utilities.

Functions

execute_parallel(fun, execution_iter[, ...])	Execute concurrent futures with an established cluster.
execute_single(fun, input_obj[, worker])	Execute a serial compute on a single core.

Classes

SmartParallelJob(obj, execution_iter[, ...])	Single node parallel compute manager with smart data flushing.
SpawnProcessPool(*args[, loggers])	An adaptation of concurrent futures ProcessPoolExecutor with spawn processes instead of fork or forkserver.
SubprocessManager()	Base class to handle subprocess execution.