CMS 3D CMS Logo

Public Member Functions

Impl::Test::Test Class Reference

Inherits Configuration::DataProcessing::Scenario::Scenario.

List of all members.

Public Member Functions

def alcaSkim
def dqmHarvesting
def expressMergepacking
def expressProcessing
def promptReco
def skimming

Detailed Description

_Test_

Test Scenario

Definition at line 15 of file Test.py.


Member Function Documentation

def Impl::Test::Test::alcaSkim (   self,
  skims 
)
_alcaSkim_

Given a skeleton process install the alcareco sequences and
skims.
For each skim name in the list of skims, install the appropriate
output module with the name of the skim

Definition at line 38 of file Test.py.

00039                              :
00040         """
00041         _alcaSkim_
00042 
00043         Given a skeleton process install the alcareco sequences and
00044         skims.
00045         For each skim name in the list of skims, install the appropriate
00046         output module with the name of the skim
00047 
00048         """
00049         return cms.Process("ALCARECO")
00050         
        
def Impl::Test::Test::dqmHarvesting (   self,
  datasetName,
  runNumber,
  globalTag,
  args 
)
_dqmHarvesting_

build a DQM Harvesting configuration

this method can be used to test an extra scenario, all the 
ConfigBuilder options can be overwritten by using **args. This will be
useful for testing with real jobs.

Arguments:

datasetName - aka workflow name for DQMServer, this is the name of the
dataset containing the harvested run
runNumber - The run being harvested
globalTag - The global tag being used
inputFiles - The list of LFNs being harvested

Definition at line 51 of file Test.py.

00052                                                                        :
00053         """
00054         _dqmHarvesting_
00055 
00056         build a DQM Harvesting configuration
00057 
00058         this method can be used to test an extra scenario, all the 
00059         ConfigBuilder options can be overwritten by using **args. This will be
00060         useful for testing with real jobs.
00061 
00062         Arguments:
00063         
00064         datasetName - aka workflow name for DQMServer, this is the name of the
00065         dataset containing the harvested run
00066         runNumber - The run being harvested
00067         globalTag - The global tag being used
00068         inputFiles - The list of LFNs being harvested
00069 
00070         """
00071         options = defaultOptions
00072         options.scenario = "cosmics"
00073         options.step = "HARVESTING:dqmHarvesting"
00074         options.isMC = False
00075         options.isData = True
00076         options.beamspot = None
00077         options.eventcontent = None
00078         options.name = "EDMtoMEConvert"
00079         options.conditions = "FrontierConditions_GlobalTag,%s" % globalTag
00080         options.arguments = ""
00081         options.evt_type = ""
00082         options.filein = []
00083 
00084         options.__dict__.update(args)
00085  
00086         process = cms.Process("HARVESTING")
00087         process.source = cms.Source("PoolSource")
00088         configBuilder = ConfigBuilder(options, process = process)
00089         configBuilder.prepare()
00090 
00091         #
00092         # customise process for particular job
00093         #
00094         process.source.processingMode = cms.untracked.string('RunsAndLumis')
00095         process.source.fileNames = cms.untracked(cms.vstring())
00096         process.maxEvents.input = -1
00097         process.dqmSaver.workflow = datasetName
00098         if args.has_key('saveByLumiSection') and \
00099                 args.get('saveByLumiSection', ''):
00100             process.dqmSaver.saveByLumiSection = int(args['saveByLumiSection'])
00101         if args.has_key('referenceFile') and args.get('referenceFile', ''):
00102             process.DQMStore.referenceFileName = \
00103                                 cms.untracked.string(args['referenceFile'])
00104 
00105         return process
00106 

def Impl::Test::Test::expressMergepacking (   self,
  outputModules 
)
_expressMergepacking_

Build/customise a mergepacking configuration

Definition at line 121 of file Test.py.

00122                                                  :
00123         """
00124         _expressMergepacking_
00125 
00126         Build/customise a mergepacking configuration
00127 
00128         """
00129         return cms.Process("MPack")
00130 
    
def Impl::Test::Test::expressProcessing (   self,
  globalTag 
)
_expressProcessing_

Build an express processing configuration for this scenario.

Express processing runs conversion, reco and alca reco on each
streamer file in the express stream and writes out RAW, RECO and
a combined ALCA file that gets mergepacked in a later step

Definition at line 107 of file Test.py.

00108                                           :
00109         """
00110         _expressProcessing_
00111 
00112         Build an express processing configuration for this scenario.
00113 
00114         Express processing runs conversion, reco and alca reco on each
00115         streamer file in the express stream and writes out RAW, RECO and
00116         a combined ALCA file that gets mergepacked in a later step
00117 
00118         """
00119         return cms.Process("Express")
00120 

def Impl::Test::Test::promptReco (   self,
  globalTag,
  skims = [],
  writeTiers = ['RECO',
  ALCARECO 
)
_installPromptReco_

given a skeleton process object and references
to the output modules for the products it produces,
install the standard reco sequences and event content for this
scenario

Definition at line 24 of file Test.py.

00025                                                                                  :
00026         """
00027         _installPromptReco_
00028 
00029         given a skeleton process object and references
00030         to the output modules for the products it produces,
00031         install the standard reco sequences and event content for this
00032         scenario
00033 
00034         """
00035         return cms.Process("RECO")
00036 
00037 

def Impl::Test::Test::skimming (   self,
  skims 
)
_skimming_

Given a process install the sequences for Tier 1 skimming
and the appropriate output modules

Definition at line 131 of file Test.py.

00132                               :
00133         """
00134         _skimming_
00135 
00136         Given a process install the sequences for Tier 1 skimming
00137         and the appropriate output modules
00138 
00139         """
00140         return cms.Process("Skimming")
00141         
00142