A thin subclass of pipeline.CondorDAG. More...

Inheritance diagram for python.dags.util.DAG:

Collaboration diagram for python.dags.util.DAG:

Public Member Functions
	__init__ (self, name, logpath=log_path())
	add_node (self, node, retry=3)
	write_cache (self)
Public Member Functions inherited from python.pipeline.CondorDAG
	__init__ (self, log)
	get_nodes (self)
	get_jobs (self)
	set_integer_node_names (self)
	set_dag_file (self, path)
	get_dag_file (self)
	add_maxjobs_category (self, categoryName, maxJobsNum)
	get_maxjobs_categories (self)
	write_maxjobs (self, fh, category)
	write_sub_files (self)
	write_concrete_dag (self)
	write_dag (self)
	write_script (self)

Public Attributes
	basename = name.replace(".dag","")
dict	jobsDict = {}
list	output_cache = []

Detailed Description

A thin subclass of pipeline.CondorDAG.

Extra features include an add_node() method and a cache writing method. Also includes some standard setup, e.g., log file paths etc.

Definition at line 126 of file util.py.

Constructor & Destructor Documentation

◆ init()

python.dags.util.DAG.__init__	(	self,
		name,
		logpath = log_path() )

Definition at line 133 of file util.py.

Member Function Documentation

◆ add_node()

python.dags.util.DAG.add_node	(	self,
		node,
		retry = 3 )

Add a CondorDAGNode to this DAG. The CondorJob that the node uses is
also added to the list of Condor jobs in the DAG so that a list of the
submit files needed by the DAG can be maintained. Each unique CondorJob
will be added once to prevent duplicate submit files being written.
@param node: CondorDAGNode to add to the CondorDAG.

Reimplemented from python.pipeline.CondorDAG.

Definition at line 145 of file util.py.

◆ write_cache()

python.dags.util.DAG.write_cache ( self )

Definition at line 150 of file util.py.

Member Data Documentation

◆ basename

python.dags.util.DAG.basename = name.replace(".dag","")

Definition at line 134 of file util.py.

◆ jobsDict

dict python.dags.util.DAG.jobsDict = {}

Definition at line 142 of file util.py.

◆ output_cache

list python.dags.util.DAG.output_cache = []

Definition at line 143 of file util.py.

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

/home/abuild/rpmbuild/BUILD/gstlal-1.13.0-build/build_python313/python/dags/util.py

Public Member Functions

Public Attributes