Integration/test/testSubProcess_cfg.py

0001 import FWCore.ParameterSet.Config as cms
0002 process = cms.Process("FIRST")
0003
0004 process.Tracer = cms.Service('Tracer',
0005   dumpEventSetupInfo = cms.untracked.bool(True)
0006 )
0007
0008 process.load("FWCore.MessageLogger.MessageLogger_cfi")
0009
0010 process.MessageLogger.cerr.threshold = 'INFO'
0011 process.MessageLogger.cerr.INFO.limit = 100
0012
0013 process.options = cms.untracked.PSet(
0014     #forceEventSetupCacheClearOnNewRun = cms.untracked.bool(True),
0015     numberOfStreams = cms.untracked.uint32(1),
0016     numberOfConcurrentRuns = cms.untracked.uint32(1),
0017     numberOfConcurrentLuminosityBlocks = cms.untracked.uint32(1)
0018 )
0019
0020 process.maxEvents = cms.untracked.PSet(
0021     input = cms.untracked.int32(30)
0022 )
0023
0024 process.source = cms.Source("EmptySource",
0025     firstRun = cms.untracked.uint32(1),
0026     firstLuminosityBlock = cms.untracked.uint32(1),
0027     firstEvent = cms.untracked.uint32(1),
0028     numberEventsInLuminosityBlock = cms.untracked.uint32(4),
0029     numberEventsInRun = cms.untracked.uint32(10)
0030 )
0031
0032 process.DoodadESSource = cms.ESSource("DoodadESSource"
0033                                       , appendToDataLabel = cms.string('abc')
0034                                       , test2 = cms.untracked.string('z')
0035 )
0036
0037 process.CPU = cms.Service("CPU")
0038 process.ZombieKillerService = cms.Service("ZombieKillerService")
0039 process.JobReportService = cms.Service("JobReportService")
0040
0041 # ---------------------------------------------------------------
0042
0043 copyProcess = cms.Process("COPY")
0044 process.addSubProcess(cms.SubProcess(copyProcess))
0045
0046 # The following services are intended to test the isProcessWideService
0047 # function which is defined in some services. These services
0048 # should never be constructed and ignored, because
0049 # The service from the top level process should be used.
0050 # They intentionally have an illegal parameter to fail
0051 # if they are ever constructed.
0052 copyProcess.MessageLogger = cms.Service("MessageLogger",
0053     intentionallyIllegalParameter = cms.bool(True)
0054 )
0055 copyProcess.CPU = cms.Service("CPU",
0056     intentionallyIllegalParameter = cms.bool(True)
0057 )
0058 copyProcess.InitRootHandlers = cms.Service("InitRootHandlers",
0059     intentionallyIllegalParameter = cms.bool(True)
0060 )
0061 copyProcess.ZombieKillerService = cms.Service("ZombieKillerService",
0062     intentionallyIllegalParameter = cms.bool(True)
0063 )
0064 copyProcess.JobReportService = cms.Service("JobReportService",
0065     intentionallyIllegalParameter = cms.bool(True)
0066 )
0067 copyProcess.SiteLocalConfigService = cms.Service("SiteLocalConfigService",
0068     intentionallyIllegalParameter = cms.bool(True)
0069 )
0070 copyProcess.AdaptorConfig = cms.Service("AdaptorConfig",
0071     intentionallyIllegalParameter = cms.bool(True)
0072 )
0073
0074 copyProcess.DoodadESSource = cms.ESSource("DoodadESSource"
0075                                           , appendToDataLabel = cms.string('abc')
0076                                           , test2 = cms.untracked.string('zz')
0077 )
0078
0079 # ---------------------------------------------------------------
0080
0081 prodProcess = cms.Process("PROD")
0082 copyProcess.addSubProcess(cms.SubProcess(prodProcess))
0083
0084 prodProcess.DoodadESSource = cms.ESSource("DoodadESSource"
0085                                           , appendToDataLabel = cms.string('abcd')
0086                                           , test2 = cms.untracked.string('z')
0087 )
0088
0089 prodProcess.thingWithMergeProducer = cms.EDProducer("ThingWithMergeProducer")
0090
0091 prodProcess.p1 = cms.Path(prodProcess.thingWithMergeProducer)
0092
0093 prodProcess.get = cms.EDAnalyzer("EventSetupRecordDataGetter",
0094     toGet = cms.VPSet(cms.PSet(
0095         record = cms.string('GadgetRcd'),
0096         data = cms.vstring('edmtest::Doodad/abcd')
0097     ) ),
0098     verbose = cms.untracked.bool(True)
0099 )
0100
0101 prodProcess.noPut = cms.EDProducer("ThingWithMergeProducer",
0102     noPut = cms.untracked.bool(True)
0103 )
0104
0105 prodProcess.putInt = cms.EDProducer("IntProducer",
0106     ivalue = cms.int32(6)
0107 )
0108
0109 prodProcess.putInt2 = cms.EDProducer("IntProducer",
0110     ivalue = cms.int32(6)
0111 )
0112
0113 prodProcess.putInt3 = cms.EDProducer("IntProducer",
0114     ivalue = cms.int32(6)
0115 )
0116
0117 prodProcess.getInt = cms.EDAnalyzer("TestFindProduct",
0118   inputTags = cms.untracked.VInputTag(
0119       cms.InputTag("putInt"),
0120   ),
0121   expectedSum = cms.untracked.int32(180),
0122   inputTagsNotFound = cms.untracked.VInputTag(
0123   )
0124 )
0125
0126 prodProcess.path1 = cms.Path(prodProcess.get * prodProcess.putInt * prodProcess.putInt2 * prodProcess.putInt3 * prodProcess.getInt)
0127
0128
0129
0130 prodProcess.path2 = cms.Path(prodProcess.noPut)
0131
0132 # ---------------------------------------------------------------
0133
0134 copy2Process = cms.Process("COPY2")
0135 prodProcess.addSubProcess(cms.SubProcess(copy2Process))
0136
0137 copy2Process.DoodadESSource = cms.ESSource("DoodadESSource"
0138                                            , appendToDataLabel = cms.string('abc')
0139                                            , test2 = cms.untracked.string('z')
0140 )
0141
0142 # ---------------------------------------------------------------
0143
0144 prod2Process = cms.Process("PROD2")
0145 copy2Process.addSubProcess(cms.SubProcess(prod2Process,
0146     outputCommands = cms.untracked.vstring(
0147         "keep *",
0148         "drop *_putInt_*_*"),
0149 ))
0150 prod2Process.DoodadESSource = cms.ESSource("DoodadESSource"
0151                                            , appendToDataLabel = cms.string('abc')
0152                                            , test2 = cms.untracked.string('zz')
0153 )
0154
0155 prod2Process.WhatsItESProducer = cms.ESProducer("WhatsItESProducer")
0156
0157 prod2Process.thingWithMergeProducer = cms.EDProducer("ThingWithMergeProducer")
0158
0159 # Reusing some code I used for testing merging, although in this
0160 # context it has nothing to do with merging.
0161 prod2Process.testmerge = cms.EDAnalyzer("TestMergeResults",
0162
0163     expectedProcessHistoryInRuns = cms.untracked.vstring(
0164         'PROD',            # Run 1
0165         'PROD2',
0166         'PROD',            # Run 2
0167         'PROD2',
0168         'PROD',            # Run 3
0169         'PROD2'
0170     )
0171 )
0172
0173 prod2Process.dependsOnNoPut = cms.EDProducer("ThingWithMergeProducer",
0174     labelsToGet = cms.untracked.vstring('noPut')
0175 )
0176
0177 prod2Process.test = cms.EDAnalyzer('RunLumiEventAnalyzer',
0178     verbose = cms.untracked.bool(True),
0179     expectedRunLumiEvents = cms.untracked.vuint32(
0180 1,   0,   0,
0181 1,   1,   0,
0182 1,   1,   1,
0183 1,   1,   2,
0184 1,   1,   3,
0185 1,   1,   4,
0186 1,   1,   0,
0187 1,   2,   0,
0188 1,   2,   5,
0189 1,   2,   6,
0190 1,   2,   7,
0191 1,   2,   8,
0192 1,   2,   0,
0193 1,   3,   0,
0194 1,   3,   9,
0195 1,   3,   10,
0196 1,   3,   0,
0197 1,   0,   0,
0198 2,   0,   0,
0199 2,   1,   0,
0200 2,   1,   1,
0201 2,   1,   2,
0202 2,   1,   3,
0203 2,   1,   4,
0204 2,   1,   0,
0205 2,   2,   0,
0206 2,   2,   5,
0207 2,   2,   6,
0208 2,   2,   7,
0209 2,   2,   8,
0210 2,   2,   0,
0211 2,   3,   0,
0212 2,   3,   9,
0213 2,   3,   10,
0214 2,   3,   0,
0215 2,   0,   0,
0216 3,   0,   0,
0217 3,   1,   0,
0218 3,   1,   1,
0219 3,   1,   2,
0220 3,   1,   3,
0221 3,   1,   4,
0222 3,   1,   0,
0223 3,   2,   0,
0224 3,   2,   5,
0225 3,   2,   6,
0226 3,   2,   7,
0227 3,   2,   8,
0228 3,   2,   0,
0229 3,   3,   0,
0230 3,   3,   9,
0231 3,   3,   10,
0232 3,   3,   0,
0233 3,   0,   0
0234 )
0235 )
0236
0237 prod2Process.get = cms.EDAnalyzer("EventSetupRecordDataGetter",
0238     toGet = cms.VPSet(cms.PSet(
0239         record = cms.string('GadgetRcd'),
0240         data = cms.vstring('edmtest::Doodad/abc')
0241     ) ),
0242     verbose = cms.untracked.bool(True)
0243 )
0244
0245 prod2Process.getInt = cms.EDAnalyzer("TestFindProduct",
0246   inputTags = cms.untracked.VInputTag(
0247   ),
0248   expectedSum = cms.untracked.int32(0),
0249   inputTagsNotFound = cms.untracked.VInputTag(
0250     cms.InputTag("putInt"),
0251   )
0252 )
0253
0254 prod2Process.out = cms.OutputModule("PoolOutputModule",
0255     fileName = cms.untracked.string('testSubProcess.root')
0256 )
0257
0258 prod2Process.path1 = cms.Path(prod2Process.thingWithMergeProducer)
0259
0260 prod2Process.path2 = cms.Path(prod2Process.test*prod2Process.testmerge)
0261
0262 prod2Process.path3 = cms.Path(prod2Process.get*prod2Process.getInt)
0263
0264 prod2Process.path4 = cms.Path(prod2Process.dependsOnNoPut)
0265
0266 prod2Process.endPath1 = cms.EndPath(prod2Process.out)
0267 # ---------------------------------------------------------------
0268
0269 prod2ProcessAlt = cms.Process("PROD2ALT")
0270 copy2Process.addSubProcess(cms.SubProcess(prod2ProcessAlt,
0271     outputCommands = cms.untracked.vstring(
0272         "keep *",
0273         "drop *_putInt_*_*"),
0274 ))
0275 prod2ProcessAlt.DoodadESSource = cms.ESSource("DoodadESSource"
0276                                            , appendToDataLabel = cms.string('abc')
0277                                            , test2 = cms.untracked.string('zz')
0278 )
0279
0280 prod2ProcessAlt.WhatsItESProducer = cms.ESProducer("WhatsItESProducer")
0281
0282 prod2ProcessAlt.thingWithMergeProducer = cms.EDProducer("ThingWithMergeProducer")
0283
0284 # Reusing some code I used for testing merging, although in this
0285 # context it has nothing to do with merging.
0286 prod2ProcessAlt.testmerge = cms.EDAnalyzer("TestMergeResults",
0287
0288     expectedProcessHistoryInRuns = cms.untracked.vstring(
0289         'PROD',            # Run 1
0290         'PROD2ALT',
0291         'PROD',            # Run 2
0292         'PROD2ALT',
0293         'PROD',            # Run 3
0294         'PROD2ALT'
0295     )
0296 )
0297
0298 prod2ProcessAlt.dependsOnNoPut = cms.EDProducer("ThingWithMergeProducer",
0299     labelsToGet = cms.untracked.vstring('noPut')
0300 )
0301
0302 prod2ProcessAlt.test = cms.EDAnalyzer('RunLumiEventAnalyzer',
0303     verbose = cms.untracked.bool(True),
0304     expectedRunLumiEvents = cms.untracked.vuint32(
0305 1,   0,   0,
0306 1,   1,   0,
0307 1,   1,   1,
0308 1,   1,   2,
0309 1,   1,   3,
0310 1,   1,   4,
0311 1,   1,   0,
0312 1,   2,   0,
0313 1,   2,   5,
0314 1,   2,   6,
0315 1,   2,   7,
0316 1,   2,   8,
0317 1,   2,   0,
0318 1,   3,   0,
0319 1,   3,   9,
0320 1,   3,   10,
0321 1,   3,   0,
0322 1,   0,   0,
0323 2,   0,   0,
0324 2,   1,   0,
0325 2,   1,   1,
0326 2,   1,   2,
0327 2,   1,   3,
0328 2,   1,   4,
0329 2,   1,   0,
0330 2,   2,   0,
0331 2,   2,   5,
0332 2,   2,   6,
0333 2,   2,   7,
0334 2,   2,   8,
0335 2,   2,   0,
0336 2,   3,   0,
0337 2,   3,   9,
0338 2,   3,   10,
0339 2,   3,   0,
0340 2,   0,   0,
0341 3,   0,   0,
0342 3,   1,   0,
0343 3,   1,   1,
0344 3,   1,   2,
0345 3,   1,   3,
0346 3,   1,   4,
0347 3,   1,   0,
0348 3,   2,   0,
0349 3,   2,   5,
0350 3,   2,   6,
0351 3,   2,   7,
0352 3,   2,   8,
0353 3,   2,   0,
0354 3,   3,   0,
0355 3,   3,   9,
0356 3,   3,   10,
0357 3,   3,   0,
0358 3,   0,   0
0359 )
0360 )
0361
0362 prod2ProcessAlt.get = cms.EDAnalyzer("EventSetupRecordDataGetter",
0363     toGet = cms.VPSet(cms.PSet(
0364         record = cms.string('GadgetRcd'),
0365         data = cms.vstring('edmtest::Doodad/abc')
0366     ) ),
0367     verbose = cms.untracked.bool(True)
0368 )
0369
0370 prod2ProcessAlt.getInt = cms.EDAnalyzer("TestFindProduct",
0371   inputTags = cms.untracked.VInputTag(
0372   ),
0373   expectedSum = cms.untracked.int32(0),
0374   inputTagsNotFound = cms.untracked.VInputTag(
0375     cms.InputTag("putInt"),
0376   )
0377 )
0378
0379 prod2ProcessAlt.out = cms.OutputModule("PoolOutputModule",
0380     fileName = cms.untracked.string('testSubProcessAlt.root')
0381 )
0382
0383 prod2ProcessAlt.path1 = cms.Path(prod2ProcessAlt.thingWithMergeProducer)
0384
0385 prod2ProcessAlt.path2 = cms.Path(prod2ProcessAlt.test*prod2ProcessAlt.testmerge)
0386
0387 prod2ProcessAlt.path3 = cms.Path(prod2ProcessAlt.get*prod2ProcessAlt.getInt)
0388
0389 prod2ProcessAlt.path4 = cms.Path(prod2ProcessAlt.dependsOnNoPut)
0390
0391 prod2ProcessAlt.endPath1 = cms.EndPath(prod2ProcessAlt.out)