FWCore/Integration/test/test_TestInterProcessProd_cfg.py - master - githubmirror/cmssw

FWCore/Integration/test/test_TestInterProcessProd_cfg.py

44 строки2 KB

Chris Jones

Switch parameter to @python_config to avoid possible name collisions

06 фев 2020, 18:54

06 фев 2020, 18:54252c9d9

import FWCore.ParameterSet.Config as cms


class ThingExternalProcessProducer(cms.EDProducer):
    def __init__(self, prod):
        self.__dict__['_prod'] = prod
        super(cms.EDProducer,self).__init__('TestInterProcessProd')
    def __setattr__(self, name, value):
        setattr(self._prod, name, value)
    def __getattr__(self, name):
        if name =='_prod':
            return self.__dict__['_prod']
        return getattr(self._prod, name)
    def clone(self, **params):
        returnValue = ThingExternalProcessProducerProducer.__new__(type(self))
        returnValue.__init__(self._prod.clone())
        return returnValue
    def insertInto(self, parameterSet, myname):
        newpset = parameterSet.newPSet()
        newpset.addString(True, "@module_label", self.moduleLabel_(myname))
        newpset.addString(True, "@module_type", self.type_())
        newpset.addString(True, "@module_edm_type", cms.EDProducer.__name__)
        newpset.addString(True, "@external_type", self._prod.type_())
        newpset.addString(False,"@python_config", self._prod.dumpPython())
        self._prod.insertContentsInto(newpset)
        parameterSet.addPSet(True, self.nameInProcessDesc_(myname), newpset)


_generator = cms.EDProducer("ThingProducer", nThings = cms.int32(100), grow=cms.bool(True), offsetDelta = cms.int32(1))

process = cms.Process("TEST")

process.source = cms.Source("EmptySource")

process.maxEvents.input = 10;

process.thing = ThingExternalProcessProducer(_generator)

process.p = cms.Path(process.thing)

process.getter = cms.EDAnalyzer("edmtest::ThingAnalyzer")

process.o = cms.EndPath(process.getter)
process.options.numberOfThreads = 4