gstlal 1.13.0
Loading...
Searching...
No Matches
python.pipeline.CondorDAGJob Class Reference
Inheritance diagram for python.pipeline.CondorDAGJob:
Collaboration diagram for python.pipeline.CondorDAGJob:

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)

Detailed Description

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.

Constructor & Destructor Documentation

◆ __init__()

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.

Member Function Documentation

◆ add_var_arg()

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.

◆ add_var_condor_cmd()

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.

◆ add_var_opt()

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.

◆ create_node()

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.

◆ get_grid_site()

python.pipeline.CondorDAGJob.get_grid_site ( self)
Return the grid site for this node

Definition at line 526 of file pipeline.py.

◆ set_grid_site()

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.


The documentation for this class was generated from the following file: