alphatwirl.concurrently.SubprocessRunner

class alphatwirl.concurrently.SubprocessRunner(pipe=False)

__init__(pipe=False)

Initialize self. See help(type(self)) for accurate signature.

Methods

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