jade.jobs.job_runner.JobRunner

class jade.jobs.job_runner.JobRunner(config, output, batch_id=0)

Bases: JobManagerBase

Manages execution of jobs on a node.

Methods

get_batch_post_process_config()	Get the batch post-process config data
get_completed_results()	Get results of completed jobs.
get_num_jobs()	Get the number of jobs to execute.
get_results_summmary()	Get a job results.
get_results_summmary_report()	Get a summary of job results in text form.
run_jobs([distributed_submitter, verbose, ...])	Run the jobs.

Attributes

config
event_filename
node_id	Return the node ID of the current system.

property node_id

Return the node ID of the current system.

Return type:

str

run_jobs(distributed_submitter=True, verbose=False, num_parallel_processes_per_node=None)

Run the jobs.

Parameters:

• distributed_submitter (bool) – If True, make cluster updates.

• verbose (bool) – If True, enable debug logging.

• num_parallel_processes_per_node (int) – Number of processes to run in parallel; defaults to num CPUs

Return type:

Status

get_batch_post_process_config()

Get the batch post-process config data

get_completed_results()

Get results of completed jobs.

Return type:

list of Result

get_num_jobs()

Get the number of jobs to execute.

Return type:

int

get_results_summmary()

Get a job results.

Return type:

dict

get_results_summmary_report()

Get a summary of job results in text form.

Return type:

str