Demo/test/rundemo_cfg.py

0001 from builtins import range
0002 import FWCore.ParameterSet.Config as cms
0003 from DQMServices.Core.DQMEDAnalyzer import DQMEDAnalyzer
0004 from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
0005
0006
0007 process = cms.Process("TEST")
0008 process.DQMStore = cms.Service("DQMStore")
0009 process.MessageLogger = cms.Service("MessageLogger")
0010
0011 process.options = cms.untracked.PSet()
0012 process.options.numberOfThreads = cms.untracked.uint32(1)
0013 process.options.numberOfStreams = cms.untracked.uint32(1)
0014
0015 process.source = cms.Source("EmptySource", numberEventsInRun = cms.untracked.uint32(10),
0016                             firstLuminosityBlock = cms.untracked.uint32(1),
0017                             firstEvent = cms.untracked.uint32(1),
0018                             numberEventsInLuminosityBlock = cms.untracked.uint32(5))
0019
0020 process.maxEvents = cms.untracked.PSet( input = cms.untracked.int32(10) )
0021
0022 process.ana1 = DQMEDAnalyzer("DemoNormalDQMEDAnalyzer",
0023   folder = cms.string("DemoSubsystemNormal1"),
0024 )
0025
0026 process.ana2 = DQMEDAnalyzer("DemoNormalDQMEDAnalyzer",
0027   folder = cms.string("DemoSubsystemNormal2"),
0028 )
0029
0030 process.ana3 = DQMEDAnalyzer("DemoGlobalDQMEDAnalyzer",
0031   folder = cms.string("DemoSubsystemGlobal1"),
0032 )
0033
0034 process.ana4 = DQMEDAnalyzer("DemoGlobalDQMEDAnalyzer",
0035   folder = cms.string("DemoSubsystemGlobal2"),
0036 )
0037
0038 process.ana5 = DQMEDAnalyzer("DemoOneDQMEDAnalyzer",
0039   folder = cms.string("DemoSubsystemOne1"),
0040 )
0041
0042 process.ana6 = DQMEDAnalyzer("DemoOneDQMEDAnalyzer",
0043   folder = cms.string("DemoSubsystemOne2"),
0044 )
0045
0046 process.harv1 = DQMEDHarvester("DemoHarvester",
0047   target = cms.string("DemoSubsystemNormal1"),
0048 )
0049
0050 process.harv2 = DQMEDHarvester("DemoHarvester",
0051   target = cms.string("DemoSubsystemNormal2"),
0052 )
0053
0054 process.harv3 = DQMEDHarvester("DemoRunHarvester",
0055   target = cms.string("DemoSubsystemGlobal1"),
0056 )
0057
0058 process.harv4 = DQMEDHarvester("DemoRunHarvester",
0059   target = cms.string("DemoSubsystemOne1"),
0060 )
0061
0062 process.harv5 = DQMEDHarvester("DemoHarvester",
0063   target = cms.string("DemoSubsystemNormal1_lumisummary"),
0064   inputMEs = cms.untracked.VInputTag(
0065     cms.InputTag("harv1", "DQMGenerationHarvestingRun"),
0066     cms.InputTag("harv1", "DQMGenerationHarvestingLumi"),
0067   )
0068 )
0069
0070 process.harv6 = DQMEDHarvester("DemoRunHarvester",
0071   target = cms.string("DemoSubsystemGlobal1_runsummary"),
0072   inputMEs = cms.untracked.VInputTag(
0073     cms.InputTag("harv3", "DQMGenerationHarvestingRun"),
0074   )
0075 )
0076
0077 process.demo_reco_dqm = cms.Task(process.ana1, process.ana2, process.ana3, process.ana4, process.ana5, process.ana6)
0078 process.demo_harvesting = cms.Task(process.harv1, process.harv2, process.harv3, process.harv4, process.harv5, process.harv6)
0079
0080 process.p = cms.Path(process.demo_reco_dqm, process.demo_harvesting)
0081
0082 process.out = cms.OutputModule(
0083   "DQMRootOutputModule",
0084   fileName = cms.untracked.string("dqm_file1.root"),
0085   outputCommands = cms.untracked.vstring(
0086     'keep *'
0087   )
0088 )
0089
0090 process.dqmSaver = cms.EDAnalyzer("DQMFileSaver",
0091     convention = cms.untracked.string('Offline'),
0092     fileFormat = cms.untracked.string('ROOT'),
0093     producer = cms.untracked.string('DQM'),
0094     workflow = cms.untracked.string('/A/B/C'),
0095     dirName = cms.untracked.string('.'),
0096 )
0097
0098 process.o = cms.EndPath(process.out + process.dqmSaver)
0099
0100 #process.add_(cms.Service("Tracer",
0101 #  dumpPathsAndConsumes = cms.untracked.bool(True)
0102 #))