class alphatwirl.concurrently.HTCondorJobSubmitter(**kwargs)[source]

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’}


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