A node class that subclasses pipeline.CondorDAGNode that automates adding the node to the dag, makes sensible names and allows a list of parent nodes to be provided. More...

Inheritance diagram for python.dags.util.DAGNode:

[legend]

Collaboration diagram for python.dags.util.DAGNode:

[legend]

Public Member Functions
	__init__ (self, job, dag, parent_nodes, opts={}, input_files={}, output_files={}, input_cache_files={}, output_cache_files={}, input_cache_file_name=None)
Public Member Functions inherited from python.pipeline.CondorDAGNode
	__init__ (self, job)
	__repr__ (self)
	job (self)
	set_pre_script (self, script)
	add_pre_script_arg (self, arg)
	set_post_script (self, script)
	get_post_script (self)
	add_post_script_arg (self, arg)
	get_post_script_arg (self)
	set_name (self, name)
	get_name (self)
	set_category (self, category)
	get_category (self)
	set_priority (self, priority)
	get_priority (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)
	set_vds_group (self, group)
	get_vds_group (self)
	add_macro (self, name, value)
	add_io_macro (self, io, filename)
	add_input_macro (self, filename)
	add_output_macro (self, filename)
	add_checkpoint_macro (self, filename)
	get_opts (self)
	add_var_condor_cmd (self, command, value)
	add_var_opt (self, opt, value, short=False)
	add_file_opt (self, opt, filename, file_is_output_file=False)
	add_var_arg (self, arg, quote=False)
	add_file_arg (self, filename)
	get_args (self)
	set_retry (self, retry)
	get_retry (self)
	write_job (self, fh)
	write_category (self, fh)
	write_priority (self, fh)
	write_vars (self, fh)
	write_parents (self, fh)
	write_pre_script (self, fh)
	write_post_script (self, fh)
	write_input_files (self, fh)
	write_output_files (self, fh)
	set_log_file (self, log)
	add_parent (self, node)
	get_cmd_tuple_list (self)
	get_cmd_line (self)
	finalize (self)

Public Attributes
	input_files = input_files.copy()
	output_files = output_files.copy()
dict	cache_inputs = {}
dict	cache_outputs = {}

Detailed Description

A node class that subclasses pipeline.CondorDAGNode that automates adding the node to the dag, makes sensible names and allows a list of parent nodes to be provided.

It tends to do the "right" thing when given a job, a dag, parent nodes, dictionary options relevant to the job, a dictionary of options related to input files and a dictionary of options related to output files.

NOTE and important and subtle behavior - You can specify an option with an empty argument by setting it to "". However options set to None are simply ignored.

Definition at line 189 of file util.py.

Constructor & Destructor Documentation

◆ init()

python.dags.util.DAGNode.__init__	(	self,
		job,
		dag,
		parent_nodes,
		opts = {},
		input_files = {},
		output_files = {},
		input_cache_files = {},
		output_cache_files = {},
		input_cache_file_name = None )

Definition at line 203 of file util.py.

Member Data Documentation

◆ cache_inputs

dict python.dags.util.DAGNode.cache_inputs = {}

Definition at line 216 of file util.py.

◆ cache_outputs

dict python.dags.util.DAGNode.cache_outputs = {}

Definition at line 217 of file util.py.

◆ input_files

python.dags.util.DAGNode.input_files = input_files.copy()

Definition at line 211 of file util.py.

◆ output_files

python.dags.util.DAGNode.output_files = output_files.copy()

Definition at line 213 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