Integration/test/testProcessBlockSubProcessLooper_cfg.py

0001 import FWCore.ParameterSet.Config as cms
0002
0003 process = cms.Process("TEST")
0004
0005 process.essource = cms.ESSource("EmptyESSource",
0006     recordName = cms.string('DummyRecord'),
0007     iovIsRunNotTime = cms.bool(True),
0008     firstValid = cms.vuint32(1)
0009 )
0010 process.add_(cms.ESProducer("LoadableDummyProvider",
0011                             value = cms.untracked.int32(5)))
0012
0013 process.looper = cms.Looper("IntTestLooper",
0014     expectESValue = cms.untracked.int32(5)
0015 )
0016
0017 process.options = cms.untracked.PSet(
0018     numberOfStreams = cms.untracked.uint32(1),
0019     numberOfThreads = cms.untracked.uint32(1),
0020     numberOfConcurrentRuns = cms.untracked.uint32(1),
0021     numberOfConcurrentLuminosityBlocks = cms.untracked.uint32(1)
0022 )
0023
0024 process.source = cms.Source("PoolSource",
0025     fileNames = cms.untracked.vstring(
0026         'file:testProcessBlockMergeOfMergedFiles.root'
0027     )
0028 )
0029
0030 process.intProducerBeginProcessBlockT = cms.EDProducer("IntProducerBeginProcessBlock", ivalue = cms.int32(4000))
0031
0032 process.intProducerEndProcessBlockT = cms.EDProducer("IntProducerEndProcessBlock", ivalue = cms.int32(40000))
0033
0034 process.out = cms.OutputModule("PoolOutputModule",
0035     fileName = cms.untracked.string('testProcessBlockSubProcessLooperTest.root'),
0036     outputCommands = cms.untracked.vstring(
0037         "keep *",
0038         "drop *_*_beginProcessBlock_*",
0039         "drop *_*_endProcessBlock_*"
0040     )
0041 )
0042
0043 process.testOneOutput = cms.OutputModule("TestOneOutput",
0044     verbose = cms.untracked.bool(False),
0045     expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE', 'MERGEOFMERGED', 'TEST'),
0046     expectedWriteProcessBlockTransitions = cms.untracked.int32(24),
0047     outputCommands = cms.untracked.vstring(
0048         "keep *",
0049         "drop *_*_beginProcessBlock_*",
0050         "drop *_*_endProcessBlock_*"
0051     )
0052 )
0053
0054 process.eventIntProducer = cms.EDProducer("IntProducer", ivalue = cms.int32(1))
0055
0056 process.transientIntProducerEndProcessBlock = cms.EDProducer("TransientIntProducerEndProcessBlock",
0057     ivalue = cms.int32(90)
0058 )
0059
0060 process.nonEventIntProducer = cms.EDProducer("NonEventIntProducer",
0061     ivalue = cms.int32(1)
0062 )
0063
0064 process.p = cms.Path(
0065     process.eventIntProducer *
0066     process.transientIntProducerEndProcessBlock *
0067     process.nonEventIntProducer *
0068     process.intProducerBeginProcessBlockT *
0069     process.intProducerEndProcessBlockT
0070 )
0071
0072 process.e = cms.EndPath(
0073     process.out *
0074     process.testOneOutput
0075 )
0076
0077 readProcess = cms.Process("READ")
0078 process.addSubProcess(cms.SubProcess(readProcess,
0079     outputCommands = cms.untracked.vstring(
0080         "keep *"
0081     )
0082 ))
0083
0084 readProcess.intProducerBeginProcessBlockR = cms.EDProducer("IntProducerBeginProcessBlock", ivalue = cms.int32(5000))
0085
0086 readProcess.intProducerEndProcessBlockR = cms.EDProducer("IntProducerEndProcessBlock", ivalue = cms.int32(50000))
0087
0088 readProcess.out = cms.OutputModule("PoolOutputModule",
0089     fileName = cms.untracked.string('testProcessBlockSubProcessLooperRead.root'),
0090     outputCommands = cms.untracked.vstring(
0091         "keep *",
0092         "drop *_*_beginProcessBlock_*",
0093         "drop *_*_endProcessBlock_*"
0094     )
0095 )
0096
0097 readProcess.testOneOutput = cms.OutputModule("TestOneOutput",
0098     verbose = cms.untracked.bool(False),
0099     expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE', 'MERGEOFMERGED', 'TEST',  'READ'),
0100     expectedWriteProcessBlockTransitions = cms.untracked.int32(27),
0101     outputCommands = cms.untracked.vstring(
0102         "keep *",
0103         "drop *_*_beginProcessBlock_*",
0104         "drop *_*_endProcessBlock_*"
0105     )
0106 )
0107
0108 readProcess.p = cms.Path(
0109     readProcess.intProducerBeginProcessBlockR *
0110     readProcess.intProducerEndProcessBlockR
0111 )
0112
0113 readProcess.e = cms.EndPath(
0114     readProcess.out *
0115     readProcess.testOneOutput
0116 )
0117
0118 readAgainProcess = cms.Process("READAGAIN")
0119 readProcess.addSubProcess(cms.SubProcess(readAgainProcess,
0120     outputCommands = cms.untracked.vstring(
0121         "keep *"
0122     )
0123 ))
0124
0125 readAgainProcess.readProcessBlocksOneAnalyzer1 = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0126                                             transitions = cms.int32(99),
0127                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0128                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0129                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0130                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0131                                             expectedByRun = cms.vint32(11, 22, 3300, 4400),
0132                                             expectedSum = cms.int32(24663)
0133 )
0134
0135 readAgainProcess.readProcessBlocksOneAnalyzer2 = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0136                                             transitions = cms.int32(81),
0137                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlockM", ""),
0138                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlockM", ""),
0139                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0140                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0141                                             expectedByRun = cms.vint32(44, 44, 444, 444),
0142                                             expectedSum = cms.int32(1464)
0143 )
0144
0145 readAgainProcess.readProcessBlocksOneAnalyzer3 = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0146                                             transitions = cms.int32(72),
0147                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlockMM", ""),
0148                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlockMM", ""),
0149                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0150                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0151                                             expectedByRun = cms.vint32(644, 644, 644, 644),
0152                                             expectedSum = cms.int32(1464)
0153 )
0154
0155 readAgainProcess.readProcessBlocksOneAnalyzer4 = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0156                                             transitions = cms.int32(72),
0157                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlockT", ""),
0158                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlockT", ""),
0159                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0160                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0161                                             # The expectedByRun test cannot work because the data is from an earlier SubProcess
0162                                             expectedByRun = cms.vint32(),
0163                                             expectedFillerSum = cms.untracked.int32(396000),
0164                                             expectedSum = cms.int32(1464)
0165 )
0166
0167 readAgainProcess.readProcessBlocksOneAnalyzer5 = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0168                                             transitions = cms.int32(72),
0169                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlockR", ""),
0170                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlockR", ""),
0171                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0172                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0173                                             # The expectedByRun test cannot work because the data is from an earlier SubProcess
0174                                             expectedByRun = cms.vint32(),
0175                                             expectedFillerSum = cms.untracked.int32(495000),
0176                                             expectedSum = cms.int32(1464),
0177                                             consumesBeginProcessBlockNotFound = cms.InputTag("intProducerBeginProcessBlockT"),
0178                                             consumesEndProcessBlockNotFound = cms.InputTag("intProducerEndProcessBlockT"),
0179                                             expectedCacheSize = cms.untracked.uint32(7)
0180 )
0181
0182 readAgainProcess.intProducerBeginProcessBlockRA = cms.EDProducer("IntProducerBeginProcessBlock", ivalue = cms.int32(100000))
0183
0184 readAgainProcess.intProducerEndProcessBlockRA = cms.EDProducer("IntProducerEndProcessBlock", ivalue = cms.int32(1000000))
0185
0186 readAgainProcess.out = cms.OutputModule("PoolOutputModule",
0187     fileName = cms.untracked.string('testProcessBlockSubProcessLooperReadAgain.root'),
0188     outputCommands = cms.untracked.vstring(
0189         "keep *",
0190         "drop *_*_beginProcessBlock_*",
0191         "drop *_*_endProcessBlock_*"
0192     )
0193 )
0194
0195 readAgainProcess.testOneOutput = cms.OutputModule("TestOneOutput",
0196     verbose = cms.untracked.bool(False),
0197     expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE', 'MERGEOFMERGED', 'TEST',  'READ', 'READAGAIN'),
0198     expectedWriteProcessBlockTransitions = cms.untracked.int32(30),
0199     outputCommands = cms.untracked.vstring(
0200         "keep *",
0201         "drop *_*_beginProcessBlock_*",
0202         "drop *_*_endProcessBlock_*"
0203     )
0204 )
0205
0206 readAgainProcess.p = cms.Path(
0207     readAgainProcess.intProducerBeginProcessBlockRA *
0208     readAgainProcess.intProducerEndProcessBlockRA *
0209     readAgainProcess.readProcessBlocksOneAnalyzer1 *
0210     readAgainProcess.readProcessBlocksOneAnalyzer2 *
0211     readAgainProcess.readProcessBlocksOneAnalyzer3 *
0212     readAgainProcess.readProcessBlocksOneAnalyzer4 *
0213     readAgainProcess.readProcessBlocksOneAnalyzer5
0214 )
0215
0216 readAgainProcess.e = cms.EndPath(
0217     readAgainProcess.out *
0218     readAgainProcess.testOneOutput
0219 )