ample.util.workers_util module¶

Created on Feb 28, 2013

@author: jmht

class JobServer[source]¶

Bases: object

empty_job_queue()[source]¶

setJobs(jobs)[source]¶

Add the list of jobs we are to run

start(nproc=None, early_terminate=False, check_success=None, monitor=None)[source]¶

run_scripts(job_scripts, monitor=None, check_success=None, early_terminate=None, nproc=None, job_time=None, job_name=None, submit_cluster=None, submit_qtype=None, submit_queue=None, submit_pe_lsf=None, submit_pe_sge=None, submit_array=None, submit_max_array=None)[source]¶

run_scripts_cluster(job_scripts, monitor=None, job_time=None, job_name=None, submit_qtype=None, submit_queue=None, submit_pe_lsf=None, submit_pe_sge=None, submit_array=None, submit_max_array=None, nproc=None)[source]¶

run_scripts_serial(job_scripts, nproc=None, monitor=None, early_terminate=None, check_success=None)[source]¶