DTTtrigWorkflow.DTttrigWorkflow Class Reference

Inheritance diagram for DTTtrigWorkflow.DTttrigWorkflow:

Public Member Functions
def	__init__ (self, options)
def	add_parser_options (cls, subparser_container)
	CLI creation #. More...
def	get_output_db (self, workflow_mode, command)
def	prepare_residuals_all (self)
def	prepare_residuals_check (self)
def	prepare_residuals_correction (self)
def	prepare_residuals_dump (self)
def	prepare_residuals_submit (self)
	prepare functions for residuals # More...
def	prepare_timeboxes_all (self)
def	prepare_timeboxes_check (self)
def	prepare_timeboxes_correction (self)
def	prepare_timeboxes_dump (self)
def	prepare_timeboxes_submit (self)
	Prepare functions for timeboxes #. More...
def	prepare_timeboxes_write (self)
def	prepare_validation_all (self)
def	prepare_validation_check (self)
def	prepare_validation_submit (self)
	prepare functions for validation # More...
def	prepare_validation_write (self)
def	prepare_workflow (self)
def	summary (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_db_dict
	output_db_file
	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 ttrig workflow jobs

Definition at line 12 of file DTTtrigWorkflow.py.

Constructor & Destructor Documentation

__init__()

def DTTtrigWorkflow.DTttrigWorkflow.__init__	(		self,
			options
	)

Definition at line 14 of file DTTtrigWorkflow.py.

    def __init__(self, options):
        # call parent constructor
        super( DTttrigWorkflow, self ).__init__( options )

        self.outpath_command_tag = "TTrigCalibration"
        # Dict to map workflow modes to output file name
        output_file_dict ={ "timeboxes" : "DTTimeBoxes.root",
                            "residuals" : 'residuals.root',
                            "validation" : "DQM.root"
                            }
        # Dict to map workflow modes to output folders in main path
        self.outpath_workflow_mode_dict = {
                                            "timeboxes" : "TimeBoxes",
                                            "residuals" : "Residuals",
                                            "validation" : "TtrigValidation"
                                           }
       # Dict to map workflow modes to database file name
        self.output_db_dict = { "timeboxes" : {
                                          "write": "ttrig_timeboxes_uncorrected_"
                                                    + self.tag
                                                    + ".db",
                                          "correction": "ttrig_timeboxes_"
                                                        + self.tag
                                                        + ".db"
                                         },
                           "residuals" : "ttrig_residuals_" + self.tag + ".db"}
        self.output_file = output_file_dict[self.options.workflow_mode]
        self.output_files = [self.output_file]

Member Function Documentation

add_parser_options()

def DTTtrigWorkflow.DTttrigWorkflow.add_parser_options	(		cls,
			subparser_container
	)

CLI creation #.

Definition at line 268 of file DTTtrigWorkflow.py.

References CLIHelper.CLIHelper.get_check_options_parser(), CLIHelper.CLIHelper.get_common_options_parser(), CLIHelper.CLIHelper.get_dump_options_parser(), CLIHelper.CLIHelper.get_input_db_options_parser(), CLIHelper.CLIHelper.get_local_input_db_options_parser(), CLIHelper.CLIHelper.get_submission_options_parser(), and CLIHelper.CLIHelper.get_write_options_parser().

    def add_parser_options(cls, subparser_container):
        ttrig_parser = subparser_container.add_parser( "ttrig",
        #parents=[mutual_parent_parser, common_parent_parser],
        help = "" ) # What does ttrig


        
        ttrig_subparsers = ttrig_parser.add_subparsers( dest="workflow_mode",
            help="Possible workflow modes",)
        
        ttrig_timeboxes_subparser = ttrig_subparsers.add_parser( "timeboxes",
            help = "" )
        ttrig_residuals_subparser = ttrig_subparsers.add_parser( "residuals",
            help = "" )
        ttrig_validation_subparser = ttrig_subparsers.add_parser( "validation",
            help = "" )
        
        ttrig_timeboxes_subparsers = ttrig_timeboxes_subparser.add_subparsers( dest="command",
            help="Possible commands for timeboxes")
        ttrig_timeboxes_submit_parser = ttrig_timeboxes_subparsers.add_parser(
            "submit",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                    super(DTttrigWorkflow,cls).get_submission_options_parser(),
                    super(DTttrigWorkflow,cls).get_input_db_options_parser()],
            help = "Submit job to the GRID via crab3")

        ttrig_timeboxes_check_parser = ttrig_timeboxes_subparsers.add_parser(
            "check",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                    super(DTttrigWorkflow,cls).get_check_options_parser(),],
            help = "Check status of submitted jobs")

        ttrig_timeboxes_write_parser = ttrig_timeboxes_subparsers.add_parser(
            "write",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                     super(DTttrigWorkflow,cls).get_write_options_parser()
                    ],
            help = "Write result from root output to text file")

        ttrig_timeboxes_correction_parser = ttrig_timeboxes_subparsers.add_parser(
            "correction",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                     super(DTttrigWorkflow,cls).get_local_input_db_options_parser()
                    ],
            help = "Perform correction on uncorrected ttrig database")

        ttrig_timeboxes_dump_parser = ttrig_timeboxes_subparsers.add_parser(
            "dump",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                     super(DTttrigWorkflow,cls).get_dump_options_parser()],
            help = "Dump database to text file")

        ttrig_timeboxes_all_parser = ttrig_timeboxes_subparsers.add_parser(
            "all",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                     super(DTttrigWorkflow,cls).get_submission_options_parser(),
                     super(DTttrigWorkflow,cls).get_check_options_parser(),
                     super(DTttrigWorkflow,cls).get_input_db_options_parser(),
                     super(DTttrigWorkflow,cls).get_local_input_db_options_parser(),
                     super(DTttrigWorkflow,cls).get_write_options_parser(),
                     super(DTttrigWorkflow,cls).get_dump_options_parser()
                    ],
            help = "Perform all steps: submit, check, write, correction,"\
                   "dump in this order")

        
        ttrig_residuals_subparsers = ttrig_residuals_subparser.add_subparsers( dest="command",
            help="Possible commands for residuals")
        ttrig_residuals_submit_parser = ttrig_residuals_subparsers.add_parser(
            "submit",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                    super(DTttrigWorkflow,cls).get_submission_options_parser(),
                    super(DTttrigWorkflow,cls).get_check_options_parser(),
                    super(DTttrigWorkflow,cls).get_local_input_db_options_parser(),
                    super(DTttrigWorkflow,cls).get_input_db_options_parser()],
            help = "Submit job to the GRID via crab3")

        ttrig_residuals_check_parser = ttrig_residuals_subparsers.add_parser(
            "check",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                    super(DTttrigWorkflow,cls).get_check_options_parser(),],
            help = "Check status of submitted jobs")

        ttrig_residuals_correct_parser = ttrig_residuals_subparsers.add_parser(
            "correction",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                    super(DTttrigWorkflow,cls).get_write_options_parser(),
                    super(DTttrigWorkflow,cls).get_local_input_db_options_parser(),
                    super(DTttrigWorkflow,cls).get_input_db_options_parser()],
            help = "Perform residual corrections")
        ttrig_residuals_correct_parser.add_argument("--globaltag",
            help="Alternative globalTag. Otherwise the gt for sunmission is used")

        ttrig_residuals_dump_parser = ttrig_residuals_subparsers.add_parser(
            "dump",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                     super(DTttrigWorkflow,cls).get_dump_options_parser()],
            help = "Dump database to text file")

        ttrig_residuals_all_parser = ttrig_residuals_subparsers.add_parser(
            "all",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                    super(DTttrigWorkflow,cls).get_submission_options_parser(),
                    super(DTttrigWorkflow,cls).get_check_options_parser(),
                    super(DTttrigWorkflow,cls).get_write_options_parser(),
                    super(DTttrigWorkflow,cls).get_local_input_db_options_parser(),
                    super(DTttrigWorkflow,cls).get_dump_options_parser(),
                    super(DTttrigWorkflow,cls).get_input_db_options_parser()],
            help = "Perform all steps: submit, check, correct, dump")

        
        ttrig_validation_subparsers = ttrig_validation_subparser.add_subparsers( dest="command",
            help="Possible commands for residuals")

        ttrig_validation_submit_parser = ttrig_validation_subparsers.add_parser(
            "submit",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                    super(DTttrigWorkflow,cls).get_submission_options_parser(),
                    super(DTttrigWorkflow,cls).get_check_options_parser(),
                    super(DTttrigWorkflow,cls).get_local_input_db_options_parser(),
                    super(DTttrigWorkflow,cls).get_input_db_options_parser()],
            help = "Submit job to the GRID via crab3")


        ttrig_validation_check_parser = ttrig_validation_subparsers.add_parser(
            "check",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                    super(DTttrigWorkflow,cls).get_check_options_parser(),],
            help = "Check status of submitted jobs")

        ttrig_validation_write_parser = ttrig_validation_subparsers.add_parser(
            "write",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                    super(DTttrigWorkflow,cls).get_write_options_parser()],
            help = "Create summary for validation")

        ttrig_validation_all_parser = ttrig_validation_subparsers.add_parser(
            "all",
            parents=[super(DTttrigWorkflow,cls).get_common_options_parser(),
                    super(DTttrigWorkflow,cls).get_submission_options_parser(),
                    super(DTttrigWorkflow,cls).get_check_options_parser(),
                    super(DTttrigWorkflow,cls).get_write_options_parser(),
                    super(DTttrigWorkflow,cls).get_local_input_db_options_parser(),
                    super(DTttrigWorkflow,cls).get_input_db_options_parser()],
            help = "Perform all steps: submit, check, summary")

get_output_db()

def DTTtrigWorkflow.DTttrigWorkflow.get_output_db	(		self,
			workflow_mode,
			command
	)

Definition at line 56 of file DTTtrigWorkflow.py.

References DTTtrigWorkflow.DTttrigWorkflow.output_db_dict.

Referenced by DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_correction(), DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_dump(), DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_correction(), and DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_dump().

    def get_output_db(self, workflow_mode, command):
        output_db_file = self.output_db_dict[workflow_mode]
        if isinstance(output_db_file, dict):
            return output_db_file[command]
        return output_db_file

prepare_residuals_all()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_all

(

self

)

Definition at line 214 of file DTTtrigWorkflow.py.

References DTT0WireWorkflow.DTT0WireWorkflow.all_commands, and DTTtrigWorkflow.DTttrigWorkflow.all_commands.

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

prepare_residuals_check()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_check

(

self

)

Definition at line 164 of file DTTtrigWorkflow.py.

References DTWorkflow.DTWorkflow.load_options_command().

    def prepare_residuals_check(self):
        self.load_options_command("submit")

prepare_residuals_correction()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_correction

(

self

)

Definition at line 167 of file DTTtrigWorkflow.py.

References DTWorkflow.DTWorkflow.add_local_calib_db(), DTWorkflow.DTWorkflow.add_local_custom_db(), DTWorkflow.DTWorkflow.add_local_vdrift_db(), DTTtrigWorkflow.DTttrigWorkflow.get_output_db(), DTWorkflow.DTWorkflow.load_options_command(), tools.loadCmsProcess(), DTCalibrationWorker.DTCalibrationWorker.options, DTWorkflow.DTWorkflow.options, DTT0WireWorkflow.DTT0WireWorkflow.output_file, DTTtrigWorkflow.DTttrigWorkflow.output_file, DTWorkflow.DTWorkflow.prepare_common_write(), DTT0WireWorkflow.DTT0WireWorkflow.process, DTTtrigWorkflow.DTttrigWorkflow.process, DTT0WireWorkflow.DTT0WireWorkflow.pset_name, DTTtrigWorkflow.DTttrigWorkflow.pset_name, DTT0WireWorkflow.DTT0WireWorkflow.pset_template, DTTtrigWorkflow.DTttrigWorkflow.pset_template, DTWorkflow.DTWorkflow.result_path(), str, and DTWorkflow.DTWorkflow.write_pset_file().

    def prepare_residuals_correction(self):
        self.pset_name = "dtTTrigResidualCorrection_cfg.py"
        self.pset_template = 'CalibMuon.DTCalibration.dtTTrigResidualCorrection_cfg'
        self.process = tools.loadCmsProcess(self.pset_template)
        self.load_options_command("submit")
        self.process.source.firstRun = cms.untracked.uint32(self.options.run)
        self.process.GlobalTag.globaltag = cms.string(str(self.options.globaltag))

        tag = self.prepare_common_write()
        if self.options.inputT0DB:
            log.warning("Option inputT0DB not supported for residual corrections")

        if self.options.inputDBTag:
            self.add_local_custom_db(local=True)
        if self.options.inputVDriftDB:
            self.add_local_vdrift_db(local=True)
        if self.options.inputCalibDB:
            self.add_local_calib_db(local=True)
        # Change DB label if running on Cosmics
        if self.options.datasettype == "Cosmics":
            self.process.dtTTrigResidualCorrection.dbLabel = 'cosmics'
            self.process.dtTTrigResidualCorrection.correctionAlgoConfig.dbLabel = 'cosmics'
        ttrig_ResidCorr_db = os.path.abspath( os.path.join(self.result_path,
                                              self.get_output_db("residuals", "write")))
        self.process.PoolDBOutputService.connect = 'sqlite_file:%s' % ttrig_ResidCorr_db
        rootfile_path = os.path.abspath( os.path.join(self.result_path, self.output_file))
        merged_file = os.path.join(self.result_path, self.output_file)
        self.process.dtTTrigResidualCorrection.correctionAlgoConfig.residualsRootFile = merged_file
        self.write_pset_file()

prepare_residuals_dump()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_dump

(

self

)

Definition at line 197 of file DTTtrigWorkflow.py.

References DTTtrigWorkflow.DTttrigWorkflow.get_output_db(), DTWorkflow.DTWorkflow.load_options_command(), DTCalibrationWorker.DTCalibrationWorker.options, DTWorkflow.DTWorkflow.options, DTWorkflow.DTWorkflow.prepare_common_dump(), DTT0WireWorkflow.DTT0WireWorkflow.pset_name, DTTtrigWorkflow.DTttrigWorkflow.pset_name, DTT0WireWorkflow.DTT0WireWorkflow.pset_template, DTTtrigWorkflow.DTttrigWorkflow.pset_template, DTWorkflow.DTWorkflow.result_path(), and DTWorkflow.DTWorkflow.write_pset_file().

    def prepare_residuals_dump(self):
        self.pset_name = 'dumpDBToFile_ResidCorr_cfg.py'
        self.pset_template = 'CalibMuon.DTCalibration.dumpDBToFile_ttrig_cfg'
        if self.options.input_dumpDB:
            dbpath = os.path.abspath(self.options.input_dumpDB)
        else:
            try:
                test = self.result_path
                self.load_options_command("write")
            except:
                pass
            dbpath = os.path.abspath( os.path.join(self.result_path,
                                                   self.get_output_db("residuals",
                                                                      "write")))
        self.prepare_common_dump(dbpath)
        self.write_pset_file()

prepare_residuals_submit()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_residuals_submit

(

self

)

prepare functions for residuals #

Definition at line 146 of file DTTtrigWorkflow.py.

References DTWorkflow.DTWorkflow.add_local_calib_db(), nano_mu_digi_cff.float, tools.loadCmsProcess(), DTCalibrationWorker.DTCalibrationWorker.options, DTWorkflow.DTWorkflow.options, DTT0WireWorkflow.DTT0WireWorkflow.output_file, DTTtrigWorkflow.DTttrigWorkflow.output_file, DTWorkflow.DTWorkflow.prepare_common_submit(), DTT0WireWorkflow.DTT0WireWorkflow.process, DTTtrigWorkflow.DTttrigWorkflow.process, DTT0WireWorkflow.DTT0WireWorkflow.pset_name, DTTtrigWorkflow.DTttrigWorkflow.pset_name, DTT0WireWorkflow.DTT0WireWorkflow.pset_template, DTTtrigWorkflow.DTttrigWorkflow.pset_template, str, and DTWorkflow.DTWorkflow.write_pset_file().

    def prepare_residuals_submit(self):
        self.pset_name = 'dtResidualCalibration_cfg.py'
        self.pset_template = 'CalibMuon.DTCalibration.dtResidualCalibration_cfg'
        if self.options.datasettype == "Cosmics":
            self.pset_template = 'CalibMuon.DTCalibration.dtResidualCalibration_cosmics_cfg'
        self.process = tools.loadCmsProcess(self.pset_template)
        #~ self.process.GlobalTag.globaltag = cms.string(self.options.globaltag)
        self.process.GlobalTag.globaltag = cms.string(str(self.options.globaltag))
        self.process.dtResidualCalibration.rootFileName = self.output_file
        self.prepare_common_submit()
        if self.options.fromMuons:
            self.process.dtResidualCalibration.Muons = cms.InputTag("muons")
        if self.options.histoRange:
            self.process.dtResidualCalibration.histogramRange = cms.double(float(self.options.histoRange))
        if self.options.inputCalibDB:
            self.add_local_calib_db()
        self.write_pset_file()

prepare_timeboxes_all()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_all

(

self

)

Definition at line 138 of file DTTtrigWorkflow.py.

    def prepare_timeboxes_all(self):
        # individual prepare functions for all tasks will be called in
        # main implementation of all
        self.all_commands=["submit", "check", "write", "correction", "dump"]

prepare_timeboxes_check()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_check

(

self

)

Definition at line 80 of file DTTtrigWorkflow.py.

References DTWorkflow.DTWorkflow.load_options_command().

    def prepare_timeboxes_check(self):
        self.load_options_command("submit")

prepare_timeboxes_correction()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_correction

(

self

)

Definition at line 99 of file DTTtrigWorkflow.py.

References DTWorkflow.DTWorkflow.add_local_calib_db(), DTTtrigWorkflow.DTttrigWorkflow.get_output_db(), DTWorkflow.DTWorkflow.load_options_command(), tools.loadCmsProcess(), DTCalibrationWorker.DTCalibrationWorker.options, DTWorkflow.DTWorkflow.options, DTT0WireWorkflow.DTT0WireWorkflow.process, DTTtrigWorkflow.DTttrigWorkflow.process, DTT0WireWorkflow.DTT0WireWorkflow.pset_name, DTTtrigWorkflow.DTttrigWorkflow.pset_name, DTT0WireWorkflow.DTT0WireWorkflow.pset_template, DTTtrigWorkflow.DTttrigWorkflow.pset_template, DTWorkflow.DTWorkflow.result_path(), str, FWLite.ElectronMVAID.tag, Entry< T >.tag, tnp::TagProbePair.tag, MeasurementEstimator::OpaquePayload.tag, cond::persistency::IOVEditorData.tag, Inspector.Inspector.tag, BeamSpotFakeConditions.tag, FWLite.WorkingPoints.tag, TrackListMerger::TkEDGetTokenss.tag, MuIsolatorResultProducer< BT >::DepositConf.tag, DQMNet::CoreObject.tag, personalPlayback.FrameworkJob.tag, DTWorkflow.DTWorkflow.tag(), and DTWorkflow.DTWorkflow.write_pset_file().

    def prepare_timeboxes_correction(self):
        self.load_options_command("submit")
        self.pset_name = 'dtTTrigCorrection_cfg.py'
        self.pset_template = "CalibMuon.DTCalibration.dtTTrigCorrection_cfg"
        ttrig_timeboxes_db = "ttrig_timeboxes_"+ self.tag + ".db"
        ttrig_timeboxes_db = os.path.join(self.result_path,
                                          self.get_output_db("timeboxes", "correction"))
        self.process = tools.loadCmsProcess(self.pset_template)
        self.process.GlobalTag.globaltag = cms.string(str(self.options.globaltag))
        self.process.source.firstRun = self.options.run
        self.process.PoolDBOutputService.connect = 'sqlite_file:%s' % ttrig_timeboxes_db

        if not self.options.inputCalibDB:
            self.options.inputCalibDB = os.path.join(self.result_path,
                                            self.get_output_db( "timeboxes", "write" ) )
        if self.options.inputVDriftDB:
            log.warning("Options inputVDriftDB has no effect for timeboxes correction")
        if self.options.inputT0DB:
            log.warning("Options inputT0DB has no effect for timeboxes correction")
        self.add_local_calib_db(local=True)
        self.write_pset_file()

prepare_timeboxes_dump()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_dump

(

self

)

Definition at line 121 of file DTTtrigWorkflow.py.

References DTTtrigWorkflow.DTttrigWorkflow.get_output_db(), DTWorkflow.DTWorkflow.load_options_command(), DTCalibrationWorker.DTCalibrationWorker.options, DTWorkflow.DTWorkflow.options, DTWorkflow.DTWorkflow.prepare_common_dump(), DTT0WireWorkflow.DTT0WireWorkflow.pset_name, DTTtrigWorkflow.DTttrigWorkflow.pset_name, DTT0WireWorkflow.DTT0WireWorkflow.pset_template, DTTtrigWorkflow.DTttrigWorkflow.pset_template, DTWorkflow.DTWorkflow.result_path(), and DTWorkflow.DTWorkflow.write_pset_file().

    def prepare_timeboxes_dump(self):
        self.pset_name = 'dumpDBToFile_ResidCorr_cfg.py'
        self.pset_template = 'CalibMuon.DTCalibration.dumpDBToFile_ttrig_cfg'
        if self.options.input_dumpDB:
            try:
                test = self.result_path
                self.load_options_command("correction")
            except:
                pass
            dbpath = os.path.abspath(self.options.input_dumpDB)
        else:
            dbpath = os.path.abspath( os.path.join(self.result_path,
                                                   self.get_output_db("timeboxes",
                                                                      "correction")))
        self.prepare_common_dump(dbpath)
        self.write_pset_file()

prepare_timeboxes_submit()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_submit

(

self

)

Prepare functions for timeboxes #.

Definition at line 64 of file DTTtrigWorkflow.py.

    def prepare_timeboxes_submit(self):
        self.pset_name = 'dtTTrigCalibration_cfg.py'
        self.pset_template = 'CalibMuon.DTCalibration.dtTTrigCalibration_cfg'
        if self.options.datasettype == "Cosmics":
            self.pset_template = 'CalibMuon.DTCalibration.dtTTrigCalibration_cosmics_cfg'
        log.debug('Using pset template ' + self.pset_template)
        self.process = tools.loadCmsProcess(self.pset_template)
        self.process.GlobalTag.globaltag = self.options.globaltag
        self.process.dtTTrigCalibration.rootFileName = self.output_file
        self.process.dtTTrigCalibration.digiLabel = self.digilabel

        if self.options.inputDBTag:
            self.add_local_custom_db()
        self.prepare_common_submit()
        self.write_pset_file()

prepare_timeboxes_write()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_timeboxes_write

(

self

)

Definition at line 83 of file DTTtrigWorkflow.py.

    def prepare_timeboxes_write(self):
        self.output_db_file = self.output_db_dict[self.options.workflow_mode]
        if isinstance(self.output_db_dict[self.options.workflow_mode], dict):
            self.output_db_file = self.output_db_file[self.options.command]
        self.prepare_common_write()
        merged_file = os.path.join(self.result_path, self.output_file)
        ttrig_uncorrected_db = os.path.join(self.result_path,
                                            self.get_output_db("timeboxes", "write"))
        self.pset_name = 'dtTTrigWriter_cfg.py'
        self.pset_template = "CalibMuon.DTCalibration.dtTTrigWriter_cfg"
        self.process = tools.loadCmsProcess(self.pset_template)
        self.process.dtTTrigWriter.rootFileName = "file:///" + merged_file
        self.process.PoolDBOutputService.connect = 'sqlite_file:%s' % ttrig_uncorrected_db
        self.process.GlobalTag.globaltag = cms.string(str(self.options.globaltag))
        self.write_pset_file()

prepare_validation_all()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_validation_all

(

self

)

Definition at line 259 of file DTTtrigWorkflow.py.

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

prepare_validation_check()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_validation_check

(

self

)

Definition at line 237 of file DTTtrigWorkflow.py.

References DTWorkflow.DTWorkflow.load_options_command().

    def prepare_validation_check(self):
        self.load_options_command("submit")

prepare_validation_submit()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_validation_submit

(

self

)

prepare functions for validation #

Definition at line 223 of file DTTtrigWorkflow.py.

References DTWorkflow.DTWorkflow.add_local_calib_db(), tools.loadCmsProcess(), DTCalibrationWorker.DTCalibrationWorker.options, DTWorkflow.DTWorkflow.options, DTWorkflow.DTWorkflow.prepare_common_submit(), DTT0WireWorkflow.DTT0WireWorkflow.process, DTTtrigWorkflow.DTttrigWorkflow.process, DTT0WireWorkflow.DTT0WireWorkflow.pset_name, DTTtrigWorkflow.DTttrigWorkflow.pset_name, DTT0WireWorkflow.DTT0WireWorkflow.pset_template, DTTtrigWorkflow.DTttrigWorkflow.pset_template, str, and DTWorkflow.DTWorkflow.write_pset_file().

    def prepare_validation_submit(self):
        self.pset_name = 'dtCalibValidation_cfg.py'
        self.pset_template = 'CalibMuon.DTCalibration.dtCalibValidation_cfg'
        if self.options.datasettype == "Cosmics":
            self.pset_template = 'CalibMuon.DTCalibration.dtCalibValidation_cosmics_cfg'
        if self.options.fromMuons:
            self.pset_template = 'CalibMuon.DTCalibration.dtCalibValidationFromMuons_cfg'
        self.process = tools.loadCmsProcess(self.pset_template)
        self.process.GlobalTag.globaltag = cms.string(str(self.options.globaltag))
        self.prepare_common_submit()
        if self.options.inputCalibDB:
            self.add_local_calib_db()
        self.write_pset_file()

prepare_validation_write()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_validation_write

(

self

)

Definition at line 240 of file DTTtrigWorkflow.py.

References tools.loadCmsProcess(), DTWorkflow.DTWorkflow.local_path(), DTCalibrationWorker.DTCalibrationWorker.options, DTWorkflow.DTWorkflow.options, DTWorkflow.DTWorkflow.prepare_common_write(), DTT0WireWorkflow.DTT0WireWorkflow.process, DTTtrigWorkflow.DTttrigWorkflow.process, DTT0WireWorkflow.DTT0WireWorkflow.pset_name, DTTtrigWorkflow.DTttrigWorkflow.pset_name, DTT0WireWorkflow.DTT0WireWorkflow.pset_template, DTTtrigWorkflow.DTttrigWorkflow.pset_template, DTWorkflow.DTWorkflow.result_path(), str, and DTWorkflow.DTWorkflow.write_pset_file().

    def prepare_validation_write(self):
        self.pset_name = 'dtDQMClient_cfg.py'
        self.pset_template = 'CalibMuon.DTCalibration.dtDQMClient_cfg'
        self.process = tools.loadCmsProcess(self.pset_template)
        self.prepare_common_write(do_hadd = False)
        dqm_files = glob.glob(os.path.join( self.local_path,
                                            "unmerged_results",
                                            "DQM_*.root"))
        dqm_files[:] = ["file://"+txt for txt in dqm_files]
        self.process.source.fileNames =  dqm_files
        self.process.dqmSaver.dirName = os.path.abspath(self.result_path)
        self.process.dqmSaver.workflow = str(self.options.datasetpath)
        if self.process.DQMStore.collateHistograms == True:
            self.process.dqmSaver.forceRunNumber = self.options.run
        self.write_pset_file()

prepare_workflow()

def DTTtrigWorkflow.DTttrigWorkflow.prepare_workflow

(

self

)

Generalized function to prepare workflow dependent on workflow mode

Definition at line 43 of file DTTtrigWorkflow.py.

References __class__< T >.__class__(), DTCalibrationWorker.DTCalibrationWorker.options, and DTWorkflow.DTWorkflow.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(self.__class__.__name__,
                                                     function_name))
        log.debug("Preparing workflow with function %s" % function_name)
        # call chosen function
        fill_function()

summary()

def DTTtrigWorkflow.DTttrigWorkflow.summary

(

self

)

Definition at line 256 of file DTTtrigWorkflow.py.

    def summary(self):
        pass

Member Data Documentation

all_commands

DTTtrigWorkflow.DTttrigWorkflow.all_commands

Definition at line 141 of file DTTtrigWorkflow.py.

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

outpath_command_tag

DTTtrigWorkflow.DTttrigWorkflow.outpath_command_tag

Definition at line 18 of file DTTtrigWorkflow.py.

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

outpath_workflow_mode_dict

DTTtrigWorkflow.DTttrigWorkflow.outpath_workflow_mode_dict

Definition at line 25 of file DTTtrigWorkflow.py.

Referenced by DTWorkflow.DTWorkflow.outpath_workflow_mode_tag().

output_db_dict

DTTtrigWorkflow.DTttrigWorkflow.output_db_dict

Definition at line 31 of file DTTtrigWorkflow.py.

Referenced by DTTtrigWorkflow.DTttrigWorkflow.get_output_db().

output_db_file

DTTtrigWorkflow.DTttrigWorkflow.output_db_file

Definition at line 84 of file DTTtrigWorkflow.py.

output_file

DTTtrigWorkflow.DTttrigWorkflow.output_file

Definition at line 40 of file DTTtrigWorkflow.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

DTTtrigWorkflow.DTttrigWorkflow.output_files

Definition at line 41 of file DTTtrigWorkflow.py.

process

DTTtrigWorkflow.DTttrigWorkflow.process

Definition at line 70 of file DTTtrigWorkflow.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(), runTauIdMVA.TauIDEmbedder.load_againstElectronMVA6(), ConfigBuilder.ConfigBuilder.loadAndRemember(), runTauIdMVA.TauIDEmbedder.loadMVA_WPs_run2_2017(), ConfigBuilder.ConfigBuilder.loadPhase2GTMenu(), 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

DTTtrigWorkflow.DTttrigWorkflow.pset_name

Definition at line 65 of file DTTtrigWorkflow.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

DTTtrigWorkflow.DTttrigWorkflow.pset_template

Definition at line 66 of file DTTtrigWorkflow.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