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.
|
|
|
|
|
|
|
|
get_cluster_jobs(self)
Returns the usertag string |
source code
|
|
|
|
get_maxjobs_categories(self)
Return an array of tuples containing (categoryName,maxJobsNum) |
source code
|
|
|
|
get_reduce_dax(self)
Return the flag that tells Pegasus to reduce the DAX based on
existing PFNs |
source code
|
|
|
|
get_static_pfn_cache(self)
Return the path to a static PFN cache |
source code
|
|
|
|
get_user_tag(self)
Returns the usertag string |
source code
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Inherited from CondorDAGNode:
__repr__,
add_checkpoint_file,
add_checkpoint_macro,
add_file_arg,
add_file_opt,
add_input_file,
add_input_macro,
add_io_macro,
add_macro,
add_output_file,
add_output_macro,
add_parent,
add_pegasus_profile,
add_post_script_arg,
add_pre_script_arg,
add_var_arg,
add_var_condor_cmd,
add_var_opt,
finalize,
get_args,
get_category,
get_checkpoint_files,
get_cmd_line,
get_cmd_tuple_list,
get_dax_collapse,
get_grid_start,
get_input_files,
get_name,
get_opts,
get_output_files,
get_pegasus_profile,
get_post_script,
get_post_script_arg,
get_priority,
get_retry,
get_vds_group,
job,
set_category,
set_dax_collapse,
set_grid_start,
set_log_file,
set_name,
set_post_script,
set_pre_script,
set_priority,
set_retry,
set_vds_group,
write_category,
write_input_files,
write_job,
write_output_files,
write_parents,
write_post_script,
write_pre_script,
write_priority,
write_vars
|