alphatwirl.concurrently.HTCondorJobSubmitter

class alphatwirl.concurrently.HTCondorJobSubmitter(**kwargs)

A dispatcher that dispatches jobs to HTCondor

Parameters:job_desc_dict (dict) – A dict representing an HTCondor job description. A copy of DEFAULT_JOB_DESC_DICT that is updated with this option will be used as a baseline job description for job submissions. This option is typically used to specify requirements, e.g., {‘request_memory’, ‘250’}

__init__(**kwargs)

Methods

__init__(**kwargs)
failed_runids(runids)	Provide the run IDs of failed jobs
poll()	Return the run IDs of the finished jobs
run(workingArea, package_index)	Submit a job
run_multiple(workingArea, package_indices)	Submit multiple jobs
terminate()	Terminate
wait()	Wait until all jobs finish and return the run IDs of the finished jobs