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