Package glue :: Module pipeline :: Class CondorDAGManJob

Class CondorDAGManJob

Condor DAGMan job class. Appropriate for setting up DAGs to run within a DAG.

Instance Methods

__init__(self, dag, dir=None, dax=None)
dag = the name of the condor dag file to run dir = the diretory in which the dag file is located

source code

add_pfn_cache(self, pfn_list)
Add an lfn pfn and pool tuple to the pfn cache

source code

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

source code

get_dag(self)
Return the name of any associated dag file

source code

get_dag_directory(self)
Get the directory where the dag will be run

source code

get_dax(self)
Return the name of any associated dax file

source code

get_pegasus_exec_dir(self)
Return the directory in which pegasus will generate all log files

source code

get_pfn_cache(self)
Return the pfn cache

source code

get_sub_file(self)
Return the name of the dag as the submit file name for the SUBDAG EXTERNAL command in the uber-dag

source code

set_dag_directory(self, dir)
Set the directory where the dag will be run

source code

set_notification(self, value)
Set the email address to send notification to.

source code

set_pegasus_exec_dir(self, dir)
Set the directory in which pegasus will generate all log files

source code

write_sub_file(self)
Do nothing as there is not need for a sub file with the SUBDAG EXTERNAL command in the uber-dag

source code

Method Details

[hide private]

create_node(self)

source code

Create a condor node from this job. This provides a basic interface to the CondorDAGManNode class. Most jobs in a workflow will subclass the CondorDAGManNode 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_dag_directory(self, dir)

source code

Set the directory where the dag will be run

Parameters:

dir - the name of the directory where the dag will be run

set_notification(self, value)

source code

Set the email address to send notification to.

Parameters:

value - email address or never for no notification.