Inheritance diagram for DTT0WireWorkflow.DTT0WireWorkflow:

Public Member Functions
def	__init__ (self, options)

def	add_parser_options (cls, subparser_container)
	CLI creation #. More...

def	prepare_all_all (self)

def	prepare_all_submit (self)

def	prepare_workflow (self)

def	submit (self)

Public Member Functions inherited from DTWorkflow.DTWorkflow
def	__init__ (self, options)

def	add_local_calib_db (self, local=False)

def	add_local_custom_db (self)

def	add_local_t0_db (self, local=False)

def	add_local_vdrift_db (self, local=False)

def	add_preselection (self)

def	add_raw_option (self)

def	all (self)

def	check (self)

def	check_missing_options (self, requirements_dict)

def	correction (self)

def	dump (self)

def	dump_options (self)

def	get_config_name (self, command="")

def	get_output_files (self, crabtask, output_path)

def	load_options (self, config_file_path)

def	load_options_command (self, command)

def	local_path (self)

def	outpath_workflow_mode_tag (self)

def	prepare_common_dump (self, db_path)

def	prepare_common_submit (self)

def	prepare_common_write (self, do_hadd=True)

def	prepare_workflow (self)

def	pset_path (self)

def	pset_template_base_bath (self)

def	remote_out_path (self)

def	result_path (self)

def	run (self)

def	runCMSSWtask (self, pset_path="")

def	submit (self)

def	tag (self)

def	user (self)

def	write (self)

def	write_pset_file (self)

Public Member Functions inherited from CLIHelper.CLIHelper
def	add_parser_options (cls, parser)

def	fill_required_options_dict (self)

def	fill_required_options_prepare_dict (self)

def	get_check_options_parser (cls)

def	get_common_options_parser (cls)

def	get_dump_options_parser (cls)

def	get_input_db_options_parser (cls)

def	get_local_input_db_options_parser (cls)

def	get_submission_options_parser (cls)

def	get_write_options_parser (cls)

Public Member Functions inherited from CrabHelper.CrabHelper
def	__init__ (self)

def	cert_info (self)

def	check_crabtask (self)

def	crab (self)

def	crab_config_filename (self)

def	crab_config_filepath (self)

def	crab_taskname (self)

def	create_crab_config (self)

def	fill_options_from_crab_config (self)

def	submit_crab_task (self)

def	voms_proxy_create (self, passphrase=None)

def	voms_proxy_time_left (self)

def	write_crabConfig (self)

Public Attributes
	all_commands

	outpath_command_tag

	outpath_workflow_mode_dict

	output_file

	output_files

	process

	pset_name

	pset_template

Public Attributes inherited from DTWorkflow.DTWorkflow
	digilabel

	files_reveived

	input_files

	options

	outpath_command_tag

	output_files

	process

	pset_name

	required_options_dict

	required_options_prepare_dict

	run_all_command

Public Attributes inherited from CrabHelper.CrabHelper
	crab_config

	crabFunctions

Additional Inherited Members
Static Public Member Functions inherited from DTWorkflow.DTWorkflow
def	addPoolDBESSource (process, moduleName, record, tag, connect='sqlite_file:', label='')

Detailed Description

This class creates and performce / submits vdrift workflow jobs

Definition at line 10 of file DTT0WireWorkflow.py.

Constructor & Destructor Documentation

def DTT0WireWorkflow.DTT0WireWorkflow.__init__	(	self,
		options
	)

Definition at line 12 of file DTT0WireWorkflow.py.

     def __init__(self, options):
         # call parent constructor
         super(DTT0WireWorkflow, self).__init__(options)
 
         self.outpath_command_tag = "T0WireCalibration"
         self.outpath_workflow_mode_dict = {"all" : "All"}
         self.output_file = 'DTTestPulses.root'
         self.output_files = ['t0.db', self.output_file, 'DQM.root']
 

Member Function Documentation

def DTT0WireWorkflow.DTT0WireWorkflow.add_parser_options	(	cls,
		subparser_container
	)

CLI creation #.

Definition at line 59 of file DTT0WireWorkflow.py.

References CLIHelper.CLIHelper.get_common_options_parser(), CLIHelper.CLIHelper.get_input_db_options_parser(), CLIHelper.CLIHelper.get_local_input_db_options_parser(), and CLIHelper.CLIHelper.get_submission_options_parser().

     def add_parser_options(cls, subparser_container):
         vdrift_parser = subparser_container.add_parser( "T0Wire",
         #parents=[mutual_parent_parser, common_parent_parser],
         help = "" ) # What does ttrig
 
         ################################################################
         #                Sub parser options for workflow modes         #
         ################################################################
         vdrift_subparsers = vdrift_parser.add_subparsers( dest="workflow_mode",
             help="Possible workflow modes",)
         ## Add all workflow modes for ttrig
         vdrift_segment_subparser = vdrift_subparsers.add_parser( "all",
             #parents=[mutual_parent_parser, common_parent_parser],
             help = "" )
         ################################################################
         #        Sub parser options for workflow mode segment          #
         ################################################################
         vdrift_segment_subparsers = vdrift_segment_subparser.add_subparsers( dest="command",
             help="Possible commands for all")
         vdrift_segment_submit_parser = vdrift_segment_subparsers.add_parser(
             "submit",
             parents=[super(DTT0WireWorkflow,cls).get_common_options_parser(),
                     super(DTT0WireWorkflow,cls).get_submission_options_parser(),
                     super(DTT0WireWorkflow,cls).get_local_input_db_options_parser(),
                     super(DTT0WireWorkflow,cls).get_input_db_options_parser()],
             help = "Run job locally as GRID submission is not supported for T0 Calibration")
 
         vdrift_segment_all_parser = vdrift_segment_subparsers.add_parser(
             "all",
             parents=[super(DTT0WireWorkflow,cls).get_common_options_parser(),
                      super(DTT0WireWorkflow,cls).get_submission_options_parser(),
                      super(DTT0WireWorkflow,cls).get_input_db_options_parser(),
                      super(DTT0WireWorkflow,cls).get_local_input_db_options_parser(),
                     ],
             help = "Perform all steps: submit, check in this order")

def DTT0WireWorkflow.DTT0WireWorkflow.prepare_all_all ( self )

Definition at line 46 of file DTT0WireWorkflow.py.

     def prepare_all_all(self):
         # individual prepare functions for all tasks will be called in
         # main implementation of all
         self.all_commands=["submit"]
 

def DTT0WireWorkflow.DTT0WireWorkflow.prepare_all_submit ( self )

Definition at line 35 of file DTT0WireWorkflow.py.

     def prepare_all_submit(self):
         self.pset_name = 'dtT0WireCalibration_cfg.py'
         self.pset_template = 'CalibMuon.DTCalibration.dtT0WireCalibration_cfg'
 
         self.process = tools.loadCmsProcess(self.pset_template)
         self.process.GlobalTag.globaltag = self.options.globaltag
         self.process.dtT0WireCalibration.rootFileName = self.output_file
 
         self.prepare_common_submit()
         self.write_pset_file()
 

def DTT0WireWorkflow.DTT0WireWorkflow.prepare_workflow ( self )

Generalized function to prepare workflow dependent on workflow mode

Definition at line 21 of file DTT0WireWorkflow.py.

Referenced by DTWorkflow.DTWorkflow.run().

     def prepare_workflow(self):
         """ Generalized function to prepare workflow dependent on workflow mode"""
         function_name = "prepare_" + self.options.workflow_mode + "_" + self.options.command
 
         try:
             fill_function = getattr(self, function_name)
         except AttributeError:
             errmsg = "Class `{}` does not implement `{}`"
             raise NotImplementedError(errmsg.format(my_cls.__class__.__name__,
                                                     method_name))
         log.debug("Preparing workflow with function %s" % function_name)
         # call chosen function
         fill_function()
 

def DTT0WireWorkflow.DTT0WireWorkflow.submit ( self )

Definition at line 51 of file DTT0WireWorkflow.py.

References DTWorkflow.DTWorkflow.runCMSSWtask().

     def submit(self):
         # Overload to run locally
         self.runCMSSWtask()
 

Member Data Documentation

DTT0WireWorkflow.DTT0WireWorkflow.all_commands

Definition at line 49 of file DTT0WireWorkflow.py.

Referenced by DTWorkflow.DTWorkflow.all(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_meantimer_all(), and DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_all().

DTT0WireWorkflow.DTT0WireWorkflow.outpath_command_tag

Definition at line 16 of file DTT0WireWorkflow.py.

Referenced by DTWorkflow.DTWorkflow.local_path(), and DTWorkflow.DTWorkflow.remote_out_path().

DTT0WireWorkflow.DTT0WireWorkflow.outpath_workflow_mode_dict

Definition at line 17 of file DTT0WireWorkflow.py.

Referenced by DTWorkflow.DTWorkflow.outpath_workflow_mode_tag().

DTT0WireWorkflow.DTT0WireWorkflow.output_file

Definition at line 18 of file DTT0WireWorkflow.py.

Referenced by mergeLHE.DefaultLHEMerger.merge(), mergeLHE.MG5LOLHEMerger.merge(), mergeLHE.ExternalCppLHEMerger.merge(), DTWorkflow.DTWorkflow.prepare_common_write(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_meantimer_submit(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_meantimer_write(), DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_correction(), DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_submit(), and DTVdriftWorkflow.DTvdriftWorkflow.prepare_segment_write().

DTT0WireWorkflow.DTT0WireWorkflow.output_files

Definition at line 19 of file DTT0WireWorkflow.py.

DTT0WireWorkflow.DTT0WireWorkflow.process

Definition at line 39 of file DTT0WireWorkflow.py.

DTT0WireWorkflow.DTT0WireWorkflow.pset_name

Definition at line 36 of file DTT0WireWorkflow.py.

Referenced by DTVdriftWorkflow.DTvdriftWorkflow.prepare_meantimer_dump(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_meantimer_submit(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_meantimer_write(), DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_correction(), DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_dump(), DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_submit(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_segment_dump(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_segment_write(), DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_correction(), DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_dump(), DTTtrigWorkflow.DTttrigWorkflow.prepare_validation_submit(), DTTtrigWorkflow.DTttrigWorkflow.prepare_validation_write(), DTWorkflow.DTWorkflow.pset_path(), and DTWorkflow.DTWorkflow.runCMSSWtask().

DTT0WireWorkflow.DTT0WireWorkflow.pset_template

Definition at line 37 of file DTT0WireWorkflow.py.

Referenced by DTVdriftWorkflow.DTvdriftWorkflow.prepare_meantimer_dump(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_meantimer_submit(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_meantimer_write(), DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_correction(), DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_dump(), DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_submit(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_segment_dump(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_segment_write(), DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_correction(), DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_dump(), DTTtrigWorkflow.DTttrigWorkflow.prepare_validation_submit(), and DTTtrigWorkflow.DTttrigWorkflow.prepare_validation_write().

Public Member Functions

Public Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation