alphatwirl.concurrently.SubprocessRunner

class alphatwirl.concurrently.SubprocessRunner(pipe=False)[source]
__init__(pipe=False)[source]

Methods

__init__([pipe])
failed_runids(runids)
poll() check if the jobs are running and return a list of pids for
run(workingArea, package_index)
run_multiple(workingArea, package_indices)
terminate()
wait() wait until all jobs finish and return a list of pids