Run a set of jobs in a local multiprocessing pool using Python's multiprocessing module. More...
Public Member Functions | |
def | __init__ (self) |
def | submit_job (self, job_id) |
Make this a no-op as we do not implement single job submission for the processing pool. More... | |
def | parse_args (self, args) |
Parse command line arguments and perform setup. More... | |
def | submit (self) |
Submit jobs to a local processing pool. More... | |
Public Member Functions inherited from Batch | |
def | default_rundir (self, job_id=None) |
def | build_cmd (self, job_id) |
This is the basic implementation of building a command to run the job from a batch system. More... | |
Public Attributes | |
pool_size | |
Public Attributes inherited from Batch | |
parser | |
script_name | |
script | |
jobstore | |
debug | |
log_dir | |
run_dir | |
check_output | |
job_ids | |
job_steps | |
start_job_num | |
end_job_num | |
config_files | |
Static Public Attributes | |
int | max_wait = 999999 |
Run a set of jobs in a local multiprocessing pool using Python's multiprocessing module.
The number of processes to spawn can be provided using the '-p' argument.
def parse_args | ( | self, | |
args | |||
) |
def submit | ( | self | ) |
def submit_job | ( | self, | |
job_id | |||
) |