File indexing completed on 2023-03-17 11:03:02
0001 import FWCore.ParameterSet.Config as cms
0002
0003 process = cms.Process("PROD1")
0004
0005 process.Tracer = cms.Service('Tracer',
0006 dumpPathsAndConsumes = cms.untracked.bool(True)
0007 )
0008
0009 process.MessageLogger = cms.Service("MessageLogger",
0010 cout = cms.untracked.PSet(
0011 Tracer = cms.untracked.PSet(
0012 limit = cms.untracked.int32(100000000)
0013 ),
0014 default = cms.untracked.PSet(
0015 limit = cms.untracked.int32(0)
0016 ),
0017 enable = cms.untracked.bool(True)
0018 )
0019 )
0020
0021 process.options = cms.untracked.PSet(
0022 numberOfStreams = cms.untracked.uint32(1),
0023 numberOfConcurrentRuns = cms.untracked.uint32(1),
0024 numberOfConcurrentLuminosityBlocks = cms.untracked.uint32(1)
0025 )
0026
0027 process.source = cms.Source("IntSource")
0028 process.maxEvents = cms.untracked.PSet(
0029 input = cms.untracked.int32(3)
0030 )
0031
0032 process.out = cms.OutputModule("PoolOutputModule",
0033 fileName = cms.untracked.string('testConsumesInfo.root'),
0034 outputCommands = cms.untracked.vstring(
0035 'keep *',
0036 'drop *_intProducerA_*_*',
0037 'drop *_intProducerB_*_*',
0038 'drop *_intProducerC_*_*',
0039 'drop *_intProducerD_*_*',
0040 'drop *_intProducerE_*_*',
0041 'drop *_intProducerF_*_*',
0042 'drop *_intProducerG_*_*',
0043 'drop *_intProducerH_*_*',
0044 'drop *_intProducerI_*_*'
0045 )
0046 )
0047
0048 process.a1 = cms.EDAnalyzer("TestFindProduct",
0049 inputTags = cms.untracked.VInputTag( cms.InputTag("source") ),
0050 expectedSum = cms.untracked.int32(12),
0051 inputTagsNotFound = cms.untracked.VInputTag(
0052 cms.InputTag("source", processName=cms.InputTag.skipCurrentProcess()),
0053 cms.InputTag("intProducer", processName=cms.InputTag.skipCurrentProcess()),
0054 cms.InputTag("intProducerU", processName=cms.InputTag.skipCurrentProcess())
0055 )
0056 )
0057
0058 process.a2 = cms.EDAnalyzer("TestFindProduct",
0059 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerA") ),
0060 expectedSum = cms.untracked.int32(300)
0061 )
0062
0063 process.a3 = cms.EDAnalyzer("TestFindProduct",
0064 inputTags = cms.untracked.VInputTag( cms.InputTag("aliasForInt") ),
0065 expectedSum = cms.untracked.int32(300)
0066 )
0067
0068 process.a4 = cms.EDAnalyzer("TestFindProduct",
0069 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerA", processName=cms.InputTag.currentProcess()) ),
0070 expectedSum = cms.untracked.int32(300)
0071 )
0072
0073 process.intProducer = cms.EDProducer("IntProducer", ivalue = cms.int32(1))
0074
0075 process.intProducerU = cms.EDProducer("IntProducer", ivalue = cms.int32(10))
0076
0077 process.intProducerA = cms.EDProducer("IntProducer", ivalue = cms.int32(100))
0078
0079 process.aliasForInt = cms.EDAlias(
0080 intProducerA = cms.VPSet(
0081 cms.PSet(type = cms.string('edmtestIntProduct')
0082 )
0083 )
0084 )
0085
0086 process.intVectorProducer = cms.EDProducer("IntVectorProducer",
0087 count = cms.int32(9),
0088 ivalue = cms.int32(11)
0089 )
0090
0091 process.test = cms.EDAnalyzer("TestContextAnalyzer",
0092 pathname = cms.untracked.string("p"),
0093 modlable = cms.untracked.string("test"))
0094
0095 process.testView1 = cms.EDAnalyzer("TestFindProduct",
0096 inputTags = cms.untracked.VInputTag(),
0097 inputTagsView = cms.untracked.VInputTag( cms.InputTag("intVectorProducer", "", "PROD1") )
0098 )
0099
0100 process.testStreamingProducer = cms.EDProducer("IntProducer",
0101 ivalue = cms.int32(111)
0102 )
0103
0104 process.testManyConsumingProducer = cms.EDProducer("ConsumingIntProducer",
0105 ivalue = cms.int32(111)
0106 )
0107
0108
0109 process.testStreamingAnalyzer = cms.EDAnalyzer("ConsumingStreamAnalyzer",
0110 valueMustMatch = cms.untracked.int32(111),
0111 moduleLabel = cms.untracked.string("testStreamingProducer")
0112 )
0113
0114 process.intProducerB = cms.EDProducer("IntProducer", ivalue = cms.int32(1000))
0115 process.intProducerC = cms.EDProducer("IntProducer", ivalue = cms.int32(1001))
0116 process.intProducerD = cms.EDProducer("IntProducer", ivalue = cms.int32(1002))
0117 process.intProducerE = cms.EDProducer("IntProducer", ivalue = cms.int32(1003))
0118 process.intProducerF = cms.EDProducer("IntProducer", ivalue = cms.int32(1004))
0119 process.intProducerG = cms.EDProducer("IntProducer", ivalue = cms.int32(1005))
0120 process.intProducerH = cms.EDProducer("IntProducer", ivalue = cms.int32(1006))
0121 process.intProducerI = cms.EDProducer("IntProducer", ivalue = cms.int32(1007))
0122
0123 process.intProducerBeginProcessBlock = cms.EDProducer("IntProducerBeginProcessBlock", ivalue = cms.int32(10000))
0124
0125 process.intProducerEndProcessBlock = cms.EDProducer("IntProducerEndProcessBlock", ivalue = cms.int32(100000))
0126
0127 process.processBlockTest1 = cms.EDAnalyzer("TestFindProduct",
0128 inputTags = cms.untracked.VInputTag(),
0129 expectedSum = cms.untracked.int32(220000),
0130 inputTagsBeginProcessBlock = cms.untracked.VInputTag(
0131 cms.InputTag("intProducerBeginProcessBlock"),
0132 cms.InputTag("intProducerBeginProcessBlock", "", "PROD1")
0133 ),
0134 inputTagsEndProcessBlock = cms.untracked.VInputTag(
0135 cms.InputTag("intProducerEndProcessBlock"),
0136 cms.InputTag("intProducerEndProcessBlock", "", "PROD1"),
0137 )
0138 )
0139
0140 process.p = cms.Path(process.intProducer * process.a1 * process.a2 * process.a3 *
0141 process.a4 *
0142 process.test * process.testView1 *
0143 process.testStreamingProducer * process.testStreamingAnalyzer *
0144 process.intProducerBeginProcessBlock *
0145 process.intProducerEndProcessBlock *
0146 process.processBlockTest1
0147 )
0148
0149 process.p2 = cms.Path(process.intProducer * process.a1 * process.a2 * process.a3)
0150
0151 process.p3 = cms.Path(
0152 process.intProducerB *
0153 process.intProducerC *
0154 process.intProducerD *
0155 process.intProducerE
0156 )
0157
0158
0159 process.p11 = cms.Path()
0160
0161 process.t = cms.Task(
0162 process.intProducerU,
0163 process.intProducerA,
0164 process.intVectorProducer,
0165 process.intProducerF,
0166 process.intProducerG,
0167 process.intProducerH,
0168 process.intProducerI
0169 )
0170
0171 process.e = cms.EndPath(process.testManyConsumingProducer+process.out, process.t)
0172
0173 process.p1ep2 = cms.EndPath()
0174
0175 process2 = cms.Process("PROD2")
0176
0177 process.addSubProcess(cms.SubProcess(process2,
0178 outputCommands = cms.untracked.vstring(
0179 "keep *",
0180 "drop *_intProducerA_*_*"
0181 )
0182 ))
0183
0184 process2.intProducerB = cms.EDProducer("IntProducer", ivalue = cms.int32(2000))
0185 process2.intProducerD = cms.EDProducer("IntProducer", ivalue = cms.int32(2002))
0186 process2.intProducerF = cms.EDProducer("IntProducer", ivalue = cms.int32(2004))
0187 process2.intProducerH = cms.EDProducer("IntProducer", ivalue = cms.int32(2006))
0188
0189 process2.task1 = cms.Task(
0190 process2.intProducerF,
0191 process2.intProducerH
0192 )
0193
0194 process2.path1 = cms.Path(
0195 process2.intProducerB *
0196 process2.intProducerD,
0197 process2.task1
0198 )
0199
0200 copyProcess = cms.Process("COPY")
0201 process2.addSubProcess(cms.SubProcess(copyProcess,
0202 outputCommands = cms.untracked.vstring(
0203 "keep *",
0204 "drop *_intProducerA_*_*"
0205 )
0206 ))
0207
0208 copyProcess.intVectorProducer = cms.EDProducer("IntVectorProducer",
0209 count = cms.int32(9),
0210 ivalue = cms.int32(12)
0211 )
0212
0213 copyProcess.testView1 = cms.EDAnalyzer("TestFindProduct",
0214 inputTags = cms.untracked.VInputTag(),
0215 inputTagsView = cms.untracked.VInputTag( cms.InputTag("intVectorProducer", "", "PROD1") ),
0216 expectedSum = cms.untracked.int32(33)
0217 )
0218
0219 copyProcess.testView2 = cms.EDAnalyzer("TestFindProduct",
0220 inputTags = cms.untracked.VInputTag(),
0221 inputTagsView = cms.untracked.VInputTag( cms.InputTag("intVectorProducer", "", "COPY") ),
0222 expectedSum = cms.untracked.int32(36)
0223 )
0224
0225 copyProcess.testView3 = cms.EDAnalyzer("TestFindProduct",
0226 inputTags = cms.untracked.VInputTag(),
0227 inputTagsView = cms.untracked.VInputTag( cms.InputTag("intVectorProducer", "", processName=cms.InputTag.currentProcess()) ),
0228 expectedSum = cms.untracked.int32(36)
0229 )
0230
0231 copyProcess.test = cms.EDAnalyzer("TestContextAnalyzer",
0232 pathname = cms.untracked.string("p3"),
0233 modlable = cms.untracked.string("test")
0234 )
0235
0236 copyProcess.thingWithMergeProducer = cms.EDProducer("ThingWithMergeProducer")
0237 copyProcess.testMergeResults = cms.EDAnalyzer("TestMergeResults")
0238
0239 copyProcess.testStreamingProducer = cms.EDProducer("IntProducer",
0240 ivalue = cms.int32(11)
0241 )
0242 copyProcess.testManyConsumingProducer = cms.EDProducer("ConsumingIntProducer",
0243 ivalue = cms.int32(11)
0244 )
0245
0246
0247 copyProcess.testStreamingAnalyzer = cms.EDAnalyzer("ConsumingStreamAnalyzer",
0248 valueMustMatch = cms.untracked.int32(11),
0249 moduleLabel = cms.untracked.string("testStreamingProducer")
0250 )
0251
0252 copyProcess.p3 = cms.Path(copyProcess.intVectorProducer * copyProcess.test * copyProcess.thingWithMergeProducer *
0253 copyProcess.testMergeResults * copyProcess.testView1 * copyProcess.testView2 * copyProcess.testView3 *
0254 copyProcess.testStreamingProducer * copyProcess.testStreamingAnalyzer)
0255
0256 copyProcess.ep1 = cms.EndPath(copyProcess.intVectorProducer+copyProcess.testManyConsumingProducer)
0257 copyProcess.ep2 = cms.EndPath()
0258
0259 copyProcess.intProducerB = cms.EDProducer("IntProducer", ivalue = cms.int32(3000))
0260 copyProcess.intProducerC = cms.EDProducer("IntProducer", ivalue = cms.int32(3001))
0261 copyProcess.intProducerF = cms.EDProducer("IntProducer", ivalue = cms.int32(3004))
0262 copyProcess.intProducerG = cms.EDProducer("IntProducer", ivalue = cms.int32(3005))
0263
0264 copyProcess.task1 = cms.Task(
0265 copyProcess.intProducerF,
0266 copyProcess.intProducerG
0267 )
0268
0269 copyProcess.path1 = cms.Path(
0270 copyProcess.intProducerB *
0271 copyProcess.intProducerC,
0272 copyProcess.task1
0273 )
0274
0275 copyProcess.a1 = cms.EDAnalyzer("TestFindProduct",
0276 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerB") ),
0277 expectedSum = cms.untracked.int32(9000)
0278 )
0279
0280 copyProcess.a2 = cms.EDAnalyzer("TestFindProduct",
0281 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerB", processName=cms.InputTag.skipCurrentProcess()) ),
0282 expectedSum = cms.untracked.int32(6000)
0283 )
0284
0285 copyProcess.a3 = cms.EDAnalyzer("TestFindProduct",
0286 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerC") ),
0287 expectedSum = cms.untracked.int32(9003)
0288 )
0289
0290 copyProcess.a4 = cms.EDAnalyzer("TestFindProduct",
0291 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerC", processName=cms.InputTag.skipCurrentProcess()) ),
0292 expectedSum = cms.untracked.int32(3003)
0293 )
0294
0295 copyProcess.a5 = cms.EDAnalyzer("TestFindProduct",
0296 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerD") ),
0297 expectedSum = cms.untracked.int32(6006)
0298 )
0299
0300 copyProcess.a6 = cms.EDAnalyzer("TestFindProduct",
0301 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerD", processName=cms.InputTag.skipCurrentProcess()) ),
0302 expectedSum = cms.untracked.int32(6006)
0303 )
0304
0305 copyProcess.a7 = cms.EDAnalyzer("TestFindProduct",
0306 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerE") ),
0307 expectedSum = cms.untracked.int32(3009)
0308 )
0309
0310 copyProcess.a8 = cms.EDAnalyzer("TestFindProduct",
0311 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerE", processName=cms.InputTag.skipCurrentProcess()) ),
0312 expectedSum = cms.untracked.int32(3009)
0313 )
0314
0315 copyProcess.a9 = cms.EDAnalyzer("TestFindProduct",
0316 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerF") ),
0317 expectedSum = cms.untracked.int32(9012)
0318 )
0319
0320 copyProcess.a10 = cms.EDAnalyzer("TestFindProduct",
0321 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerF", processName=cms.InputTag.skipCurrentProcess()) ),
0322 expectedSum = cms.untracked.int32(6012)
0323 )
0324
0325 copyProcess.a11 = cms.EDAnalyzer("TestFindProduct",
0326 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerG") ),
0327 expectedSum = cms.untracked.int32(9015)
0328 )
0329
0330 copyProcess.a12 = cms.EDAnalyzer("TestFindProduct",
0331 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerG", processName=cms.InputTag.skipCurrentProcess()) ),
0332 expectedSum = cms.untracked.int32(3015)
0333 )
0334
0335 copyProcess.a13 = cms.EDAnalyzer("TestFindProduct",
0336 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerH") ),
0337 expectedSum = cms.untracked.int32(6018)
0338 )
0339
0340 copyProcess.a14 = cms.EDAnalyzer("TestFindProduct",
0341 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerH", processName=cms.InputTag.skipCurrentProcess()) ),
0342 expectedSum = cms.untracked.int32(6018)
0343 )
0344
0345 copyProcess.a15 = cms.EDAnalyzer("TestFindProduct",
0346 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerI") ),
0347 expectedSum = cms.untracked.int32(3021)
0348 )
0349
0350 copyProcess.a16 = cms.EDAnalyzer("TestFindProduct",
0351 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerI", processName=cms.InputTag.skipCurrentProcess()) ),
0352 expectedSum = cms.untracked.int32(3021)
0353 )
0354
0355 copyProcess.a17 = cms.EDAnalyzer("TestFindProduct",
0356 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerB", processName=cms.InputTag.currentProcess()) ),
0357 expectedSum = cms.untracked.int32(9000)
0358 )
0359
0360 copyProcess.a18 = cms.EDAnalyzer("TestFindProduct",
0361 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerC", processName=cms.InputTag.currentProcess()) ),
0362 expectedSum = cms.untracked.int32(9003)
0363 )
0364
0365 copyProcess.a19 = cms.EDAnalyzer("TestFindProduct",
0366 inputTags = cms.untracked.VInputTag(),
0367 inputTagsNotFound = cms.untracked.VInputTag( cms.InputTag("intProducerD", processName=cms.InputTag.currentProcess()) )
0368 )
0369
0370 copyProcess.a20 = cms.EDAnalyzer("TestFindProduct",
0371 inputTags = cms.untracked.VInputTag(),
0372 inputTagsNotFound = cms.untracked.VInputTag( cms.InputTag("intProducerE", processName=cms.InputTag.currentProcess()) )
0373 )
0374
0375 copyProcess.a21 = cms.EDAnalyzer("TestFindProduct",
0376 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerF", processName=cms.InputTag.currentProcess()) ),
0377 expectedSum = cms.untracked.int32(9012)
0378 )
0379
0380 copyProcess.a22 = cms.EDAnalyzer("TestFindProduct",
0381 inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerG", processName=cms.InputTag.currentProcess()) ),
0382 expectedSum = cms.untracked.int32(9015)
0383 )
0384
0385 copyProcess.a23 = cms.EDAnalyzer("TestFindProduct",
0386 inputTags = cms.untracked.VInputTag(),
0387 inputTagsNotFound = cms.untracked.VInputTag( cms.InputTag("intProducerH", processName=cms.InputTag.currentProcess()) )
0388 )
0389
0390 copyProcess.a24 = cms.EDAnalyzer("TestFindProduct",
0391 inputTags = cms.untracked.VInputTag(),
0392 inputTagsNotFound = cms.untracked.VInputTag( cms.InputTag("intProducerI", processName=cms.InputTag.currentProcess()) )
0393 )
0394
0395 copyProcess.a25 = cms.EDAnalyzer("TestFindProduct",
0396 inputTags = cms.untracked.VInputTag(
0397 cms.InputTag("intProducerB", processName=cms.InputTag.currentProcess()),
0398 cms.InputTag("intProducerC"),
0399 cms.InputTag("intProducerD"),
0400 cms.InputTag("intProducerF", processName=cms.InputTag.currentProcess()),
0401 cms.InputTag("intProducerG", processName=cms.InputTag.currentProcess()),
0402 cms.InputTag("intProducerI")
0403 ),
0404 inputTagsNotFound = cms.untracked.VInputTag(
0405 cms.InputTag("intProducerE", processName=cms.InputTag.currentProcess()),
0406 cms.InputTag("intProducerH", processName=cms.InputTag.currentProcess()),
0407 cms.InputTag("intProducerQ", "INSTANCE", "DOESNOTEXIST")
0408 )
0409 )
0410
0411 copyProcess.path2 = cms.Path(
0412 copyProcess.a1 *
0413 copyProcess.a2 *
0414 copyProcess.a3 *
0415 copyProcess.a4 *
0416 copyProcess.a5 *
0417 copyProcess.a6 *
0418 copyProcess.a7 *
0419 copyProcess.a8 *
0420 copyProcess.a9 *
0421 copyProcess.a10 *
0422 copyProcess.a11 *
0423 copyProcess.a12 *
0424 copyProcess.a13 *
0425 copyProcess.a14 *
0426 copyProcess.a15 *
0427 copyProcess.a16 *
0428 copyProcess.a17 *
0429 copyProcess.a18 *
0430 copyProcess.a19 *
0431 copyProcess.a20 *
0432 copyProcess.a21 *
0433 copyProcess.a22 *
0434 copyProcess.a23 *
0435 copyProcess.a24 *
0436 copyProcess.a25
0437 )
0438
0439 copyProcess.intProducerBeginProcessBlock = cms.EDProducer("IntProducerBeginProcessBlock", ivalue = cms.int32(10001))
0440
0441 copyProcess.intProducerEndProcessBlock = cms.EDProducer("IntProducerEndProcessBlock", ivalue = cms.int32(100010))
0442
0443 copyProcess.processBlockTest1 = cms.EDAnalyzer("TestFindProduct",
0444 inputTags = cms.untracked.VInputTag(),
0445 expectedSum = cms.untracked.int32(450034),
0446
0447
0448
0449 inputTagsBeginProcessBlock = cms.untracked.VInputTag(
0450 cms.InputTag("intProducerBeginProcessBlock"),
0451 cms.InputTag("intProducerBeginProcessBlock", "", "COPY")
0452 ),
0453 inputTagsEndProcessBlock = cms.untracked.VInputTag(
0454 cms.InputTag("intProducerBeginProcessBlock"),
0455 cms.InputTag("intProducerBeginProcessBlock", "", "COPY"),
0456 cms.InputTag("intProducerEndProcessBlock"),
0457 cms.InputTag("intProducerEndProcessBlock", "", "COPY"),
0458 cms.InputTag("intProducerEndProcessBlock", "", cms.InputTag.currentProcess())
0459 ),
0460 inputTagsInputProcessBlock = cms.untracked.VInputTag(
0461 cms.InputTag("intProducerBeginProcessBlock", "", "PROD1"),
0462 cms.InputTag("intProducerEndProcessBlock", "", "PROD1")
0463 )
0464 )
0465
0466 copyProcess.testOneOutput = cms.OutputModule("TestOneOutput",
0467 verbose = cms.untracked.bool(False),
0468 expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'COPY'),
0469 expectedWriteProcessBlockTransitions = cms.untracked.int32(2),
0470 expectedProductsFromInputKept = cms.untracked.bool(False)
0471 )
0472
0473 copyProcess.path3 = cms.Path(
0474 copyProcess.intProducerBeginProcessBlock *
0475 copyProcess.intProducerEndProcessBlock *
0476 copyProcess.processBlockTest1
0477 )
0478
0479 copyProcess.endPath = cms.EndPath(copyProcess.testOneOutput)
