Integration/test/delayedreader_throw_cfg.py

0001 import FWCore.ParameterSet.Config as cms
0002 from FWCore.Framework.modules import AddIntsProducer, IntProductFilter
0003 from FWCore.Modules.modules import AsciiOutputModule
0004 from FWCore.Integration.modules import DelayedReaderThrowingSource
0005
0006 process = cms.Process("TEST")
0007
0008 process.source = DelayedReaderThrowingSource( labels = ["test", "test2", "test3"])
0009
0010 process.getter = AddIntsProducer(labels = [("test","","INPUTTEST")])
0011 process.onPath = AddIntsProducer(labels = [("test2", "", "INPUTTEST"), ("getter", "other")])
0012 process.f1 = IntProductFilter( label = "onPath", shouldProduce = True)
0013 process.f2 = IntProductFilter( label = "onPath", shouldProduce = True)
0014 process.inFront = IntProductFilter( label = "test3")
0015
0016 process.p1 = cms.Path(process.inFront+process.onPath+process.f1+process.f2)
0017 process.p3 = cms.Path(process.onPath+process.f1, cms.Task(process.getter))
0018
0019 process.p2 = cms.Path(process.onPath+process.f2)
0020
0021 #from FWCore.Modules.modules import EventContentAnalyzer import *
0022 #process.dump = EventContentAnalyzer()
0023 #process.p = cms.Path(process.dump)
0024
0025 process.out = AsciiOutputModule()
0026 process.e = cms.EndPath(process.out, cms.Task(process.getter))
0027
0028 process.maxEvents.input = 1
0029
0030 #from FWCore.Services.modules import Tracer
0031 #process.add_(Tracer())