DTT0WireWorkflow.DTT0WireWorkflow Class Reference

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

__init__()

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

add_parser_options()

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

        
        vdrift_subparsers = vdrift_parser.add_subparsers( dest="workflow_mode",
            help="Possible workflow modes",)
        
        vdrift_segment_subparser = vdrift_subparsers.add_parser( "all",
            #parents=[mutual_parent_parser, common_parent_parser],
            help = "" )
        
        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")

prepare_all_all()

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"]

prepare_all_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()

prepare_workflow()

def DTT0WireWorkflow.DTT0WireWorkflow.prepare_workflow

(

self

)

Generalized function to prepare workflow dependent on workflow mode

Definition at line 21 of file DTT0WireWorkflow.py.

References DTCalibrationWorker.DTCalibrationWorker.options, DTWorkflow.DTWorkflow.options, and validateAlignments.ValidationJobMultiIOV.options.

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()

submit()

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

all_commands

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().

outpath_command_tag

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().

outpath_workflow_mode_dict

DTT0WireWorkflow.DTT0WireWorkflow.outpath_workflow_mode_dict

Definition at line 17 of file DTT0WireWorkflow.py.

Referenced by DTWorkflow.DTWorkflow.outpath_workflow_mode_tag().

output_file

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().

output_files

DTT0WireWorkflow.DTT0WireWorkflow.output_files

Definition at line 19 of file DTT0WireWorkflow.py.

process

DTT0WireWorkflow.DTT0WireWorkflow.process

Definition at line 39 of file DTT0WireWorkflow.py.

Referenced by adaptToRunAtMiniAOD.adaptToRunAtMiniAOD.__init__(), DTWorkflow.DTWorkflow.add_local_calib_db(), DTWorkflow.DTWorkflow.add_local_custom_db(), DTWorkflow.DTWorkflow.add_local_t0_db(), DTWorkflow.DTWorkflow.add_local_vdrift_db(), DTWorkflow.DTWorkflow.add_preselection(), DTWorkflow.DTWorkflow.add_raw_option(), ConfigBuilder.ConfigBuilder.addCommon(), ConfigBuilder.ConfigBuilder.addConditions(), ConfigBuilder.ConfigBuilder.addCustomise(), ConfigBuilder.ConfigBuilder.addMaxEvents(), ConfigBuilder.ConfigBuilder.addOutput(), ConfigBuilder.ConfigBuilder.addSource(), ConfigBuilder.ConfigBuilder.addStandardSequences(), ConfigBuilder.ConfigBuilder.build_production_info(), ConfigBuilder.ConfigBuilder.completeInputCommand(), adaptToRunAtMiniAOD.adaptToRunAtMiniAOD.convertModuleToMiniAODInput(), ConfigBuilder.ConfigBuilder.finalizeFastSimHLT(), ConfigBuilder.ConfigBuilder.load(), ConfigBuilder.ConfigBuilder.loadAndRemember(), runTauIdMVA.TauIDEmbedder.loadMVA_WPs_run2_2017(), ConfigBuilder.ConfigBuilder.prepare(), ConfigBuilder.ConfigBuilder.prepare_DIGI(), ConfigBuilder.ConfigBuilder.prepare_DQM(), ConfigBuilder.ConfigBuilder.prepare_GEN(), ConfigBuilder.ConfigBuilder.prepare_HLT(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_meantimer_submit(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_meantimer_write(), ConfigBuilder.ConfigBuilder.prepare_PATFILTER(), DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_correction(), DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_submit(), DTVdriftWorkflow.DTvdriftWorkflow.prepare_segment_write(), ConfigBuilder.ConfigBuilder.prepare_SKIM(), DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_correction(), ConfigBuilder.ConfigBuilder.prepare_VALIDATION(), DTTtrigWorkflow.DTttrigWorkflow.prepare_validation_submit(), DTTtrigWorkflow.DTttrigWorkflow.prepare_validation_write(), runTauIdMVA.TauIDEmbedder.processDeepProducer(), ConfigBuilder.ConfigBuilder.renameHLTprocessInSequence(), ConfigBuilder.ConfigBuilder.renameInputTagsInSequence(), runTauIdMVA.TauIDEmbedder.runTauID(), ConfigBuilder.ConfigBuilder.scheduleSequence(), runTauIdMVA.TauIDEmbedder.tauIDMVAinputs(), and DTWorkflow.DTWorkflow.write_pset_file().

pset_name

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().

pset_template

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().

---

Generated for CMSSW Reference Manual by  1.8.14