Integration/test/test_TryToContinue_exception_output_cfg.py

0001 import FWCore.ParameterSet.Config as cms
0002
0003 process = cms.Process("TEST")
0004
0005 process.source = cms.Source("EmptySource")
0006
0007 process.options.TryToContinue = ['NotFound']
0008 process.maxEvents.input = 3
0009
0010 process.fail = cms.EDProducer("FailingProducer")
0011 process.intProd = cms.EDProducer("IntProducer", ivalue = cms.int32(10))
0012 process.dependentAnalyzer = cms.EDAnalyzer("TestFindProduct",
0013     inputTags = cms.untracked.VInputTag(["intProd"]),
0014     inputTagsNotFound = cms.untracked.VInputTag( cms.InputTag("fail")),
0015     expectedSum = cms.untracked.int32(0)
0016 )
0017
0018 process.p = cms.Path(process.dependentAnalyzer, cms.Task(process.fail,process.intProd))
0019
0020 #no direct or indirect dependency on the failed data product means no need to add to
0021 #  modulesToCallForTryToContinue
0022 process.out = cms.OutputModule("SewerModule",
0023     name=cms.string("out"),
0024     shouldPass = cms.int32(3),
0025     SelectEvents = cms.untracked.PSet(SelectEvents = cms.vstring("exception@p")),
0026     outputCommands = cms.untracked.vstring("drop *", "keep *_intProd_*_*")
0027 )
0028
0029 process.outContinueDirect = cms.OutputModule("SewerModule",
0030     name=cms.string("outNoContinueDirect"),
0031     shouldPass = cms.int32(3),
0032     SelectEvents = cms.untracked.PSet(SelectEvents = cms.vstring("exception@p")),
0033     outputCommands = cms.untracked.vstring("drop *", "keep *_fail_*_*")
0034 )
0035
0036
0037 process.options.modulesToCallForTryToContinue = [process.outContinueDirect.label_(), "dummy"]
0038
0039 process.outNoContinueDirect = cms.OutputModule("SewerModule",
0040     name=cms.string("outNoContinueDirect"),
0041     shouldPass = cms.int32(0),
0042     SelectEvents = cms.untracked.PSet(SelectEvents = cms.vstring("exception@p")),
0043     outputCommands = cms.untracked.vstring("drop *", "keep *_fail_*_*")
0044 )
0045
0046 process.e = cms.EndPath(process.out+process.outContinueDirect+process.outNoContinueDirect)
0047