Package glue :: Module pipeline :: Class CondorDAGJob

Class CondorDAGJob

CondorJob --+
            |
           CondorDAGJob

Known Subclasses:

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.

Instance Methods

[hide private]

__init__(self, universe, executable)
universe = the condor universe to run the job in.

source code

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.

source code

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.

source code

add_var_opt(self, opt, short=False)
Add a variable (or macro) option to the condor job.

source code

create_node(self)
Create a condor node from this job.

source code

get_dax_mpi_cluster(self)
Get the DAX collapse key for this node

source code

get_grid_site(self)
Return the grid site for this node

source code

set_dax_mpi_cluster(self, size)
Set the DAX collapse key for this node

source code

set_grid_site(self, site)
Set the grid site to run on.

source code

Inherited from CondorJob: add_arg, add_checkpoint_file, add_condor_cmd, add_file_arg, add_file_opt, add_ini_opts, add_input_file, add_opt, add_output_file, add_short_opt, get_args, get_checkpoint_files, get_condor_cmds, get_executable, get_executable_installed, get_grid_scheduler, get_grid_server, get_grid_type, get_input_files, get_opt, get_opts, get_output_files, get_short_opts, get_stderr_file, get_stdin_file, get_stdout_file, get_sub_file, get_universe, set_executable, set_executable_installed, set_grid_scheduler, set_grid_server, set_grid_type, set_log_file, set_notification, set_stderr_file, set_stdin_file, set_stdout_file, set_sub_file, set_universe, write_sub_file

Method Details

[hide private]

init(self, universe, executable)
(Constructor)

source code

universe = the condor universe to run the job in. executable = the executable to run in the DAG.

Parameters:

universe - the condor universe to run the job in.
executable - the executable to run.
queue - number of jobs to queue.

Overrides: CondorJob.__init__

add_var_opt(self, opt, short=False)

source code

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.

Parameters:

opt - name of option to add.

create_node(self)

source code

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.

set_grid_site(self, site)

source code

Set the grid site to run on. If not specified, will not give hint to Pegasus

Class CondorDAGJob

__init__(self, universe, executable) (Constructor)

add_var_opt(self, opt, short=False)

create_node(self)

set_grid_site(self, site)

init(self, universe, executable)
(Constructor)