HTCJob

class lsst.ctrl.bps.htcondor.HTCJob(name, label=None, initcmds=(), initdagcmds=(), initattrs=None)

Bases: object

HTCondor job for use in building DAG.

Parameters:

namestr

Name of the job

labelstr

Label that can used for grouping or lookup.

initcmdsRestrictedDict

Initial job commands for submit file.

initdagcmdsRestrictedDict

Initial commands for job inside DAG.

initattrsdict

Initial dictionary of job attributes.

Methods Summary

add_dag_cmds(new_commands)	Add DAG commands to Job (overwrite existing).
add_job_attrs(new_attrs)	Add attributes to Job (overwrite existing).
add_job_cmds(new_commands)	Add commands to Job (overwrite existing).
dump(fh)	Dump job information to output stream.
write_dag_commands(stream)	Write DAG commands for single job to output stream.
write_submit_file(submit_path[, job_subdir])	Write job description to submit file.

Methods Documentation

add_dag_cmds(new_commands)

Add DAG commands to Job (overwrite existing).

Parameters:

new_commandsdict

DAG file commands to be added to Job

add_job_attrs(new_attrs)

Add attributes to Job (overwrite existing).

Parameters:

new_attrsdict

Attributes to be added to Job

add_job_cmds(new_commands)

Add commands to Job (overwrite existing).

Parameters:

new_commandsdict

Submit file commands to be added to Job.

dump(fh)

Dump job information to output stream.

Parameters:

fhTextIOBase

Output stream

write_dag_commands(stream)

Write DAG commands for single job to output stream.

Parameters:

streamIO or str

Output Stream

write_submit_file(submit_path, job_subdir='')

Write job description to submit file.

Parameters:

submit_pathstr

Prefix path for the submit file.

job_subdirstr, optional

Template for job subdir.