File indexing completed on 2024-04-06 12:12:41
0001 import FWCore.ParameterSet.Config as cms
0002
0003 process = cms.Process("READSUBPROCESSOUTPUT")
0004
0005 process.options = cms.untracked.PSet(
0006 numberOfStreams = cms.untracked.uint32(1),
0007 numberOfThreads = cms.untracked.uint32(1),
0008 numberOfConcurrentRuns = cms.untracked.uint32(1),
0009 numberOfConcurrentLuminosityBlocks = cms.untracked.uint32(1)
0010 )
0011
0012 process.source = cms.Source("PoolSource",
0013 fileNames = cms.untracked.vstring(
0014 'file:testProcessBlockSubProcessRead.root'
0015 )
0016 )
0017
0018 process.readProcessBlocksOneAnalyzer1 = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0019 transitions = cms.int32(33),
0020 consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0021 consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0022 consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0023 consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0024 expectedByRun = cms.vint32(11, 22, 3300, 4400),
0025 expectedSum = cms.int32(8221),
0026 expectedFillerSum = cms.untracked.int32(23199),
0027 consumesBeginProcessBlockNotFound = cms.InputTag("intProducerBeginProcessBlock"),
0028 consumesEndProcessBlockNotFound = cms.InputTag("intProducerEndProcessBlock")
0029 )
0030
0031 process.readProcessBlocksOneAnalyzer2 = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0032 transitions = cms.int32(24),
0033 consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlockT", ""),
0034 consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlockT", ""),
0035 consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0036 consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0037 expectedByRun = cms.vint32(44000, 44000, 44000, 44000),
0038 expectedSum = cms.int32(488),
0039 expectedFillerSum = cms.untracked.int32(132000),
0040 consumesBeginProcessBlockNotFound = cms.InputTag("intProducerBeginProcessBlockT"),
0041 consumesEndProcessBlockNotFound = cms.InputTag("intProducerEndProcessBlockT")
0042 )
0043
0044 process.readProcessBlocksOneAnalyzer3 = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0045 transitions = cms.int32(24),
0046 consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlockR", ""),
0047 consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlockR", ""),
0048 consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0049 consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0050 expectedByRun = cms.vint32(55000, 55000, 55000, 55000),
0051 expectedSum = cms.int32(488),
0052 expectedFillerSum = cms.untracked.int32(165000),
0053 consumesBeginProcessBlockNotFound = cms.InputTag("intProducerBeginProcessBlockR"),
0054 consumesEndProcessBlockNotFound = cms.InputTag("intProducerEndProcessBlockR")
0055 )
0056
0057 process.out = cms.OutputModule("PoolOutputModule",
0058 fileName = cms.untracked.string('testProcessBlockSubProcessRead1.root')
0059 )
0060
0061 process.testOneOutput = cms.OutputModule("TestOneOutput",
0062 verbose = cms.untracked.bool(False),
0063 expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE', 'MERGEOFMERGED', 'TEST', 'READ'),
0064 expectedWriteProcessBlockTransitions = cms.untracked.int32(10)
0065 )
0066
0067 process.p = cms.Path(
0068 process.readProcessBlocksOneAnalyzer1 *
0069 process.readProcessBlocksOneAnalyzer2 *
0070 process.readProcessBlocksOneAnalyzer3
0071 )
0072
0073 process.e = cms.EndPath(
0074 process.out *
0075 process.testOneOutput
0076 )
