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.