gridtk.models

Functions

add_job(session, command_line[, name, ...])	Helper function to create a job, add the dependencies and the array jobs.
times(job)	Returns a string containing timing information for teh given job, which might be a Job or an ArrayJob.

Classes

ArrayJob(id, job_id)	This class defines one element of an array job.
Job(command_line[, name, exec_dir, log_dir, ...])	This class defines one Job that was submitted to the Job Manager.
JobDependence(waiting_job_id, waited_for_job_id)	This table defines a many-to-many relationship between Jobs.

class gridtk.models.ArrayJob(id, job_id)

Bases: Base

This class defines one element of an array job.

unique

job

id

job_id

status

result

machine_name

submit_time

start_time

finish_time

std_out_file()

std_err_file()

format(format)

Formats the current job into a nicer string to fit into a table.

class gridtk.models.Job(command_line, name=None, exec_dir=None, log_dir=None, array_string=None, queue_name='local', machine_name=None, stop_on_failure=False, **kwargs)

Bases: Base

This class defines one Job that was submitted to the Job Manager.

unique

id

submit_time

start_time

finish_time

status

result

command_line

name

queue_name

machine_name

grid_arguments

exec_dir

log_dir

stop_on_failure

array_string

submit(new_queue=None)

Sets the status of this job to ‘submitted’.

queue(new_job_id=None, new_job_name=None, queue_name=None)

Sets the status of this job to ‘queued’ or ‘waiting’.

execute(array_id=None, machine_name=None)

Sets the status of this job to ‘executing’.

finish(result, array_id=None)

Sets the status of this job to ‘success’ or ‘failure’.

refresh()

Refreshes the status information.

get_command_line()

Returns the command line for the job.

set_command_line(command_line)

Sets / overwrites the command line for the job.

get_exec_dir()

Returns the command line for the job.

get_array()

Returns the array arguments for the job; usually a string.

get_arguments()

Returns the additional options for the grid (such as the queue, memory requirements, …).

set_arguments(**kwargs)

get_jobs_we_wait_for()

get_jobs_waiting_for_us()

std_out_file(array_id=None)

std_err_file(array_id=None)

format(format, dependencies=0, limit_command_line=None)

Formats the current job into a nicer string to fit into a table.

class gridtk.models.JobDependence(waiting_job_id, waited_for_job_id)

Bases: Base

This table defines a many-to-many relationship between Jobs.

id

waiting_job

waited_for_job

waiting_job_id

waited_for_job_id

gridtk.models.add_job(session, command_line, name='job', dependencies=[], array=None, exec_dir=None, log_dir=None, stop_on_failure=False, **kwargs)

Helper function to create a job, add the dependencies and the array jobs.

gridtk.models.times(job)

Returns a string containing timing information for teh given job, which might be a Job or an ArrayJob.