|
gstlal 1.13.0
|
Public Member Functions | |
| __init__ (self, universe, executable) | |
| create_node (self) | |
| set_grid_site (self, site) | |
| get_grid_site (self) | |
| add_var_opt (self, opt, short=False) | |
| add_var_condor_cmd (self, command) | |
| add_var_arg (self, arg_index, quote=False) | |
| Public Member Functions inherited from python.pipeline.CondorJob | |
| __init__ (self, universe, executable, queue) | |
| get_executable (self) | |
| set_executable (self, executable) | |
| get_universe (self) | |
| set_universe (self, universe) | |
| get_grid_type (self) | |
| set_grid_type (self, grid_type) | |
| get_grid_server (self) | |
| set_grid_server (self, grid_server) | |
| get_grid_scheduler (self) | |
| set_grid_scheduler (self, grid_scheduler) | |
| set_executable_installed (self, installed) | |
| get_executable_installed (self) | |
| add_condor_cmd (self, cmd, value) | |
| get_condor_cmds (self) | |
| add_input_file (self, filename) | |
| add_output_file (self, filename) | |
| add_checkpoint_file (self, filename) | |
| get_input_files (self) | |
| get_output_files (self) | |
| get_checkpoint_files (self) | |
| add_arg (self, arg) | |
| add_file_arg (self, filename) | |
| get_args (self) | |
| add_opt (self, opt, value) | |
| get_opt (self, opt) | |
| add_file_opt (self, opt, filename) | |
| get_opts (self) | |
| add_short_opt (self, opt, value) | |
| get_short_opts (self) | |
| add_ini_opts (self, cp, section) | |
| set_notification (self, value) | |
| set_log_file (self, path) | |
| set_stdin_file (self, path) | |
| get_stdin_file (self) | |
| set_stderr_file (self, path) | |
| get_stderr_file (self) | |
| set_stdout_file (self, path) | |
| get_stdout_file (self) | |
| set_sub_file (self, path) | |
| get_sub_file (self) | |
| write_sub_file (self) | |
A Condor DAG job never notifies the user on completion and can have variable options that are set for a particular node in the DAG. Inherits methods from a CondorJob.
Definition at line 487 of file pipeline.py.
| python.pipeline.CondorDAGJob.__init__ | ( | self, | |
| universe, | |||
| executable ) |
universe = the condor universe to run the job in. executable = the executable to run in the DAG.
Definition at line 493 of file pipeline.py.
| python.pipeline.CondorDAGJob.add_var_arg | ( | self, | |
| arg_index, | |||
| quote = False ) |
Add a command to the submit file to allow variable (macro) arguments to be passed to the executable.
Definition at line 557 of file pipeline.py.
| python.pipeline.CondorDAGJob.add_var_condor_cmd | ( | self, | |
| command ) |
Add a condor command to the submit file that allows variable (macro) arguments to be passes to the executable.
Definition at line 547 of file pipeline.py.
| python.pipeline.CondorDAGJob.add_var_opt | ( | self, | |
| opt, | |||
| short = False ) |
Add a variable (or macro) option to the condor job. The option is added to the submit file and a different argument to the option can be set for each node in the DAG. @param opt: name of option to add.
Definition at line 532 of file pipeline.py.
| python.pipeline.CondorDAGJob.create_node | ( | self | ) |
Create a condor node from this job. This provides a basic interface to the CondorDAGNode class. Most jobs in a workflow will subclass the CondorDAGNode class and overwrite this to give more details when initializing the node. However, this will work fine for jobs with very simp input/output.
Definition at line 507 of file pipeline.py.
| python.pipeline.CondorDAGJob.get_grid_site | ( | self | ) |
Return the grid site for this node
Definition at line 526 of file pipeline.py.
| python.pipeline.CondorDAGJob.set_grid_site | ( | self, | |
| site ) |
Set the grid site to run on. If not specified, will not give hint to Pegasus
Definition at line 517 of file pipeline.py.