Inheritance diagram for python.pipeline.CondorDAGManNode:

Collaboration diagram for python.pipeline.CondorDAGManNode:

Public Member Functions
	__init__ (self, job)
	set_user_tag (self, usertag)
	get_user_tag (self)
	add_maxjobs_category (self, categoryName, maxJobsNum)
	get_maxjobs_categories (self)
	set_cluster_jobs (self, cluster)
	get_cluster_jobs (self)
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)

Detailed Description

Condor DAGMan node class. Appropriate for setting up DAGs to run within a
DAG. Adds the user-tag functionality to condor_dagman processes running in
the DAG. May also be used to extend dagman-node specific functionality.

Definition at line 1181 of file pipeline.py.

Constructor & Destructor Documentation

◆ init()

python.pipeline.CondorDAGManNode.__init__	(		self,
			job )

@job: a CondorDAGNodeJob

Definition at line 1187 of file pipeline.py.

Member Function Documentation

◆ add_maxjobs_category()

python.pipeline.CondorDAGManNode.add_maxjobs_category	(	self,
		categoryName,
		maxJobsNum )

Add a category to this DAG called categoryName with a maxjobs of maxJobsNum.
@param node: Add (categoryName,maxJobsNum) tuple to CondorDAG.__maxjobs_categories.

Definition at line 1209 of file pipeline.py.

◆ get_cluster_jobs()

python.pipeline.CondorDAGManNode.get_cluster_jobs ( self )

Returns the usertag string

Definition at line 1229 of file pipeline.py.

◆ get_maxjobs_categories()

python.pipeline.CondorDAGManNode.get_maxjobs_categories ( self )

Return an array of tuples containing (categoryName,maxJobsNum)

Definition at line 1216 of file pipeline.py.

◆ get_user_tag()

python.pipeline.CondorDAGManNode.get_user_tag ( self )

Returns the usertag string

Definition at line 1203 of file pipeline.py.

◆ set_cluster_jobs()

python.pipeline.CondorDAGManNode.set_cluster_jobs	(		self,
			cluster )

Set the type of job clustering pegasus can use to collapse jobs
@param cluster: clustering type

Definition at line 1222 of file pipeline.py.

◆ set_user_tag()

python.pipeline.CondorDAGManNode.set_user_tag	(		self,
			usertag )

Set the user tag that is passed to the analysis code.
@param user_tag: the user tag to identify the job

Definition at line 1196 of file pipeline.py.

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

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

Public Member Functions