Merge pull request #18751 from gartung/DQMEDHarvester_EDProducer3

DQMServices/Core: Change DQMEDHarvester to an edm::one::EDProducer and add alias to EDProducer from DQMEDHarvester
cms-sw · May 27, 2017 · 95d1397 · 95d1397
2 parents 7d6f617 + d0f77e1
commit 95d1397
Show file tree

Hide file tree

Showing 264 changed files with 673 additions and 404 deletions.
diff --git a/Alignment/MillePedeAlignmentAlgorithm/python/MillePedeDQMModule_cff.py b/Alignment/MillePedeAlignmentAlgorithm/python/MillePedeDQMModule_cff.py
@@ -1,7 +1,8 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
 import  Alignment.MillePedeAlignmentAlgorithm.MillePedeFileReader_cfi as MillePedeFileReader_cfi
 
-SiPixelAliDQMModule = cms.EDAnalyzer("MillePedeDQMModule",
+SiPixelAliDQMModule = DQMEDHarvester("MillePedeDQMModule",
                                      MillePedeFileReader = cms.PSet(MillePedeFileReader_cfi.MillePedeFileReader.clone())
                                      )
diff --git a/CalibTracker/SiStripChannelGain/python/SiStripGainsPCLHarvester_cfi.py b/CalibTracker/SiStripChannelGain/python/SiStripGainsPCLHarvester_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-SiStripGainsPCLHarvester = cms.EDAnalyzer(
+SiStripGainsPCLHarvester = DQMEDHarvester(
     "SiStripGainsPCLHarvester",
     Record              = cms.untracked.string('SiStripApvGainRcd'),
     CalibrationLevel    = cms.untracked.int32(0), # 0==APV, 1==Laser, 2==module

diff --git a/Calibration/EcalCalibAlgos/python/ecalPedestalPCLHarvester_cfi.py b/Calibration/EcalCalibAlgos/python/ecalPedestalPCLHarvester_cfi.py
@@ -1,5 +1,7 @@
 import FWCore.ParameterSet.Config as cms
-ECALpedestalPCLHarvester = cms.EDAnalyzer('ECALpedestalPCLHarvester',
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
+
+ECALpedestalPCLHarvester = DQMEDHarvester('ECALpedestalPCLHarvester',
                                           MinEntries = cms.int32(100), #skip channel if stat is low
                                           ChannelStatusToExclude = cms.vstring(), # db statuses to exclude
                                           checkAnomalies  = cms.bool(False), # whether or not to avoid creating sqlite file in case of many changed pedestals

diff --git a/DQM/CSCMonitorModule/python/csc_certification_info_cfi.py b/DQM/CSCMonitorModule/python/csc_certification_info_cfi.py
@@ -1,4 +1,5 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-cscCertificationInfo = cms.EDAnalyzer("CSCCertificationInfo")
+cscCertificationInfo = DQMEDHarvester("CSCCertificationInfo")
 
diff --git a/DQM/CSCMonitorModule/python/csc_daq_info_cfi.py b/DQM/CSCMonitorModule/python/csc_daq_info_cfi.py
@@ -1,4 +1,5 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-cscDaqInfo = cms.EDAnalyzer("CSCDaqInfo")
+cscDaqInfo = DQMEDHarvester("CSCDaqInfo")
 
diff --git a/DQM/CSCMonitorModule/python/csc_dcs_info_cfi.py b/DQM/CSCMonitorModule/python/csc_dcs_info_cfi.py
@@ -1,4 +1,5 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-cscDcsInfo = cms.EDAnalyzer("CSCDcsInfo")
+cscDcsInfo = DQMEDHarvester("CSCDcsInfo")
 
diff --git a/DQM/CSCMonitorModule/python/csc_dqm_offlineclient_cfi.py b/DQM/CSCMonitorModule/python/csc_dqm_offlineclient_cfi.py
@@ -1,8 +1,9 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
 from DQM.CSCMonitorModule.csc_dqm_masked_hw_cfi import *
 
-dqmCSCOfflineClient = cms.EDAnalyzer("CSCOfflineClient",
+dqmCSCOfflineClient = DQMEDHarvester("CSCOfflineClient",
 
   MASKEDHW = CSCMaskedHW,
 

diff --git a/DQM/CTPPS/python/totemRPDQMHarvester_cfi.py b/DQM/CTPPS/python/totemRPDQMHarvester_cfi.py
@@ -1,4 +1,5 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-totemRPDQMHarvester = cms.EDAnalyzer("TotemRPDQMHarvester",
+totemRPDQMHarvester = DQMEDHarvester("TotemRPDQMHarvester",
 )
diff --git a/DQM/DTMonitorClient/python/dtBlockedROChannelsTest_cfi.py b/DQM/DTMonitorClient/python/dtBlockedROChannelsTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-blockedROChannelTest = cms.EDAnalyzer("DTBlockedROChannelsTest",
+blockedROChannelTest = DQMEDHarvester("DTBlockedROChannelsTest",
                                       offlineMode = cms.untracked.bool(False),
                                       diagnosticPrescale = cms.untracked.int32(1)
                                       )

diff --git a/DQM/DTMonitorClient/python/dtCertificationSummary_cfi.py b/DQM/DTMonitorClient/python/dtCertificationSummary_cfi.py
@@ -1,5 +1,6 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtCertificationSummary = cms.EDAnalyzer("DTCertificationSummary")
+dtCertificationSummary = DQMEDHarvester("DTCertificationSummary")
 
 
diff --git a/DQM/DTMonitorClient/python/dtChamberEfficiencyClient_cfi.py b/DQM/DTMonitorClient/python/dtChamberEfficiencyClient_cfi.py
@@ -1,4 +1,5 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtChamberEfficiencyClient = cms.EDAnalyzer("DTChamberEfficiencyClient",
+dtChamberEfficiencyClient = DQMEDHarvester("DTChamberEfficiencyClient",
                                            diagnosticPrescale = cms.untracked.int32(1))
diff --git a/DQM/DTMonitorClient/python/dtChamberEfficiencyTest_cfi.py b/DQM/DTMonitorClient/python/dtChamberEfficiencyTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-chamberEfficiencyTest = cms.EDAnalyzer("DTChamberEfficiencyTest",
+chamberEfficiencyTest = DQMEDHarvester("DTChamberEfficiencyTest",
     runningStandalone = cms.untracked.bool(True),
     #Names of the quality tests: they must match those specified in "qtList"
     XEfficiencyTestName = cms.untracked.string('ChEfficiencyInRangeX'),

diff --git a/DQM/DTMonitorClient/python/dtDAQInfo_cfi.py b/DQM/DTMonitorClient/python/dtDAQInfo_cfi.py
@@ -1,5 +1,6 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtDAQInfo = cms.EDAnalyzer("DTDAQInfo")
+dtDAQInfo = DQMEDHarvester("DTDAQInfo")
 
 
diff --git a/DQM/DTMonitorClient/python/dtDCSByLumiSummary_cfi.py b/DQM/DTMonitorClient/python/dtDCSByLumiSummary_cfi.py
@@ -1,5 +1,6 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtDCSByLumiSummary = cms.EDAnalyzer("DTDCSByLumiSummary")
+dtDCSByLumiSummary = DQMEDHarvester("DTDCSByLumiSummary")
 
 
diff --git a/DQM/DTMonitorClient/python/dtDCSSummary_cfi.py b/DQM/DTMonitorClient/python/dtDCSSummary_cfi.py
@@ -1,5 +1,6 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtDCSSummary = cms.EDAnalyzer("DTDCSSummary")
+dtDCSSummary = DQMEDHarvester("DTDCSSummary")
 
 
diff --git a/DQM/DTMonitorClient/python/dtDataIntegrityTest_cfi.py b/DQM/DTMonitorClient/python/dtDataIntegrityTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dataIntegrityTest = cms.EDAnalyzer("DTDataIntegrityTest",
+dataIntegrityTest = DQMEDHarvester("DTDataIntegrityTest",
                                    diagnosticPrescale = cms.untracked.int32(1)
 )
 

diff --git a/DQM/DTMonitorClient/python/dtEfficiencyTest_cfi.py b/DQM/DTMonitorClient/python/dtEfficiencyTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-efficiencyTest = cms.EDAnalyzer("DTEfficiencyTest",
+efficiencyTest = DQMEDHarvester("DTEfficiencyTest",
     runningStandalone = cms.untracked.bool(True),
     UnassEfficiencyTestName = cms.untracked.string('UnassEfficiencyInRange'),
     #Names of the quality tests: they must match those specified in "qtList"

diff --git a/DQM/DTMonitorClient/python/dtLocalTriggerEfficiencyTest_cfi.py b/DQM/DTMonitorClient/python/dtLocalTriggerEfficiencyTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-triggerEfficiencyTest = cms.EDAnalyzer("DTLocalTriggerEfficiencyTest",
+triggerEfficiencyTest = DQMEDHarvester("DTLocalTriggerEfficiencyTest",
     # prescale factor (in luminosity blocks) to perform client analysis
     diagnosticPrescale = cms.untracked.int32(1),
     # run in online environment

diff --git a/DQM/DTMonitorClient/python/dtLocalTriggerLutTest_cfi.py b/DQM/DTMonitorClient/python/dtLocalTriggerLutTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-triggerLutTest = cms.EDAnalyzer("DTLocalTriggerLutTest",
+triggerLutTest = DQMEDHarvester("DTLocalTriggerLutTest",
     # prescale factor (in luminosity blocks) to perform client analysis
     diagnosticPrescale = cms.untracked.int32(1),
     # run in online environment

diff --git a/DQM/DTMonitorClient/python/dtLocalTriggerSynchTest_cfi.py b/DQM/DTMonitorClient/python/dtLocalTriggerSynchTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-triggerSynchTest = cms.EDAnalyzer("DTLocalTriggerSynchTest",
+triggerSynchTest = DQMEDHarvester("DTLocalTriggerSynchTest",
     # prescale factor (in luminosity blocks) to perform client analysis
     diagnosticPrescale = cms.untracked.int32(1),
     # run in online environment

diff --git a/DQM/DTMonitorClient/python/dtLocalTriggerTest_TP_cfi.py b/DQM/DTMonitorClient/python/dtLocalTriggerTest_TP_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtTPTriggerTest = cms.EDAnalyzer("DTLocalTriggerTPTest",
+dtTPTriggerTest = DQMEDHarvester("DTLocalTriggerTPTest",
     # prescale factor (in luminosity blocks) to perform client analysis
     diagnosticPrescale = cms.untracked.int32(1),
     # run in online environment

diff --git a/DQM/DTMonitorClient/python/dtLocalTriggerTest_cfi.py b/DQM/DTMonitorClient/python/dtLocalTriggerTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-triggerTest = cms.EDAnalyzer("DTLocalTriggerTest",
+triggerTest = DQMEDHarvester("DTLocalTriggerTest",
     # prescale factor (in luminosity blocks) to perform client analysis
     diagnosticPrescale = cms.untracked.int32(1),
     # run in online environment

diff --git a/DQM/DTMonitorClient/python/dtNoiseAnalysis_cfi.py b/DQM/DTMonitorClient/python/dtNoiseAnalysis_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtNoiseAnalysisMonitor = cms.EDAnalyzer("DTNoiseAnalysisTest",
+dtNoiseAnalysisMonitor = DQMEDHarvester("DTNoiseAnalysisTest",
                                         noisyCellDef = cms.untracked.int32(1500),
                                         doSynchNoise = cms.untracked.bool(False),
                                         detailedAnalysis = cms.untracked.bool(False),

diff --git a/DQM/DTMonitorClient/python/dtOccupancyTest_TP_cfi.py b/DQM/DTMonitorClient/python/dtOccupancyTest_TP_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtTPmonitorTest = cms.EDAnalyzer("DTOccupancyTest",
+dtTPmonitorTest = DQMEDHarvester("DTOccupancyTest",
                                  testPulseMode = cms.untracked.bool(True),
                                  runOnAllHitsOccupancies = cms.untracked.bool(False),
                                  runOnNoiseOccupancies = cms.untracked.bool(False),

diff --git a/DQM/DTMonitorClient/python/dtOccupancyTest_cfi.py b/DQM/DTMonitorClient/python/dtOccupancyTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtOccupancyTest = cms.EDAnalyzer("DTOccupancyTest",
+dtOccupancyTest = DQMEDHarvester("DTOccupancyTest",
                                  testPulseMode = cms.untracked.bool(False),
                                  runOnAllHitsOccupancies = cms.untracked.bool(True),
                                  runOnNoiseOccupancies = cms.untracked.bool(False),

diff --git a/DQM/DTMonitorClient/python/dtOfflineSummaryClients_cfi.py b/DQM/DTMonitorClient/python/dtOfflineSummaryClients_cfi.py
@@ -1,5 +1,6 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtOfflineSummaryClients = cms.EDAnalyzer("DTOfflineSummaryClients")
+dtOfflineSummaryClients = DQMEDHarvester("DTOfflineSummaryClients")
 
 
diff --git a/DQM/DTMonitorClient/python/dtResolutionAnalysisTest_cfi.py b/DQM/DTMonitorClient/python/dtResolutionAnalysisTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtResolutionAnalysisTest = cms.EDAnalyzer("DTResolutionAnalysisTest",
+dtResolutionAnalysisTest = DQMEDHarvester("DTResolutionAnalysisTest",
                                           diagnosticPrescale = cms.untracked.int32(1),
                                           maxGoodMeanValue = cms.untracked.double(0.005),
                                           minBadMeanValue = cms.untracked.double(0.015),

diff --git a/DQM/DTMonitorClient/python/dtResolutionAnalysisTest_hlt_cfi.py b/DQM/DTMonitorClient/python/dtResolutionAnalysisTest_hlt_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtResolutionTestHLT = cms.EDAnalyzer("DTResolutionAnalysisTest",
+dtResolutionTestHLT = DQMEDHarvester("DTResolutionAnalysisTest",
                                      diagnosticPrescale = cms.untracked.int32(1),
                                      permittedMeanRange = cms.untracked.double(0.01),
                                      permittedSigmaRange = cms.untracked.double(0.08),

diff --git a/DQM/DTMonitorClient/python/dtResolutionTestFinalCalib_cfi.py b/DQM/DTMonitorClient/python/dtResolutionTestFinalCalib_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-resolutionTest = cms.EDAnalyzer("DTResolutionAnalysisTest",
+resolutionTest = DQMEDHarvester("DTResolutionAnalysisTest",
                                  diagnosticPrescale = cms.untracked.int32(1),
                                  permittedMeanRange = cms.untracked.double(0.02),
                                  permittedSigmaRange = cms.untracked.double(0.12),

diff --git a/DQM/DTMonitorClient/python/dtResolutionTest_cfi.py b/DQM/DTMonitorClient/python/dtResolutionTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-resolutionTest = cms.EDAnalyzer("DTResolutionTest",
+resolutionTest = DQMEDHarvester("DTResolutionTest",
     runningStandalone = cms.untracked.bool(True),
     diagnosticPrescale = cms.untracked.int32(1),
     calibModule = cms.untracked.bool(True),

diff --git a/DQM/DTMonitorClient/python/dtRunConditionVarClient_cfi.py b/DQM/DTMonitorClient/python/dtRunConditionVarClient_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtRunConditionVarClient = cms.EDAnalyzer("DTRunConditionVarClient",
+dtRunConditionVarClient = DQMEDHarvester("DTRunConditionVarClient",
 
    minRangeVDrift  = cms.untracked.double(-1.),
    maxRangeVDrift  = cms.untracked.double(1.), 

diff --git a/DQM/DTMonitorClient/python/dtSegmentAnalysisTest_cfi.py b/DQM/DTMonitorClient/python/dtSegmentAnalysisTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-segmentTest = cms.EDAnalyzer("DTSegmentAnalysisTest",
+segmentTest = DQMEDHarvester("DTSegmentAnalysisTest",
                              detailedAnalysis = cms.untracked.bool(False),
                              #Perform basic diagnostic in endLumi/EndRun
                              runOnline = cms.untracked.bool(True),

diff --git a/DQM/DTMonitorClient/python/dtSegmentAnalysisTest_hlt_cfi.py b/DQM/DTMonitorClient/python/dtSegmentAnalysisTest_hlt_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtSegmentTestkHLT = cms.EDAnalyzer("DTSegmentAnalysisTest",
+dtSegmentTestkHLT = DQMEDHarvester("DTSegmentAnalysisTest",
                                    detailedAnalysis = cms.untracked.bool(False),
                                    #Perform basic diagnostic in endLumi/EndRun
                                    runOnline = cms.untracked.bool(True),

diff --git a/DQM/DTMonitorClient/python/dtSummaryClients_cfi.py b/DQM/DTMonitorClient/python/dtSummaryClients_cfi.py
@@ -1,5 +1,6 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-dtSummaryClients = cms.EDAnalyzer("DTSummaryClients")
+dtSummaryClients = DQMEDHarvester("DTSummaryClients")
 
 
diff --git a/DQM/DTMonitorClient/python/dtTriggerEfficiencyTest_cfi.py b/DQM/DTMonitorClient/python/dtTriggerEfficiencyTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-triggerEffTest = cms.EDAnalyzer("DTTriggerEfficiencyTest",
+triggerEffTest = DQMEDHarvester("DTTriggerEfficiencyTest",
     # prescale factor (in luminosity blocks) to perform client analysis
     diagnosticPrescale = cms.untracked.int32(1),
     # run in online environment

diff --git a/DQM/DTMonitorClient/python/dtTriggerLutTest_cfi.py b/DQM/DTMonitorClient/python/dtTriggerLutTest_cfi.py
@@ -1,6 +1,7 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
-triggerLutTest = cms.EDAnalyzer("DTTriggerLutTest",
+triggerLutTest = DQMEDHarvester("DTTriggerLutTest",
     # prescale factor (in luminosity blocks) to perform client analysis
     diagnosticPrescale = cms.untracked.int32(1),
     # run in online environment

diff --git a/DQM/EcalCommon/python/EcalMEFormatter_cfi.py b/DQM/EcalCommon/python/EcalMEFormatter_cfi.py
@@ -1,4 +1,5 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
 from DQM.EcalMonitorTasks.ClusterTask_cfi import ecalClusterTask
 from DQM.EcalMonitorTasks.EnergyTask_cfi import ecalEnergyTask
@@ -20,7 +21,7 @@
 from DQM.EcalMonitorClient.TrigPrimClient_cfi import ecalTrigPrimClient
 from DQM.EcalMonitorClient.SummaryClient_cfi import ecalSummaryClient
 
-ecalMEFormatter = cms.EDAnalyzer("EcalMEFormatter",
+ecalMEFormatter = DQMEDHarvester("EcalMEFormatter",
     MEs = cms.untracked.PSet(),
     verbosity = cms.untracked.int32(0)
 )

diff --git a/DQM/EcalMonitorClient/python/EcalCalibMonitorClient_cfi.py b/DQM/EcalMonitorClient/python/EcalCalibMonitorClient_cfi.py
@@ -1,4 +1,5 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
 from DQM.EcalCommon.CommonParams_cfi import ecalCommonParams
 
@@ -12,7 +13,7 @@
 from DQM.EcalMonitorClient.SummaryClient_cfi import ecalSummaryClient
 from DQM.EcalMonitorClient.CalibrationSummaryClient_cfi import ecalCalibrationSummaryClient
 
-ecalCalibMonitorClient = cms.EDAnalyzer("EcalDQMonitorClient",
+ecalCalibMonitorClient = DQMEDHarvester("EcalDQMonitorClient",
     moduleName = cms.untracked.string("EcalCalib Monitor Client"),
     # workers to be turned on
     workers = cms.untracked.vstring(

diff --git a/DQM/EcalMonitorClient/python/EcalCertification_cfi.py b/DQM/EcalMonitorClient/python/EcalCertification_cfi.py
@@ -1,10 +1,11 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
 from DQM.EcalCommon.CommonParams_cfi import ecalCommonParams
 
 from DQM.EcalMonitorClient.CertificationClient_cfi import ecalCertificationClient
 
-ecalCertification = cms.EDAnalyzer("EcalDQMonitorClient",
+ecalCertification = DQMEDHarvester("EcalDQMonitorClient",
     moduleName = cms.untracked.string("Ecal Certification Client"),
     # workers to be turned on
     workers = cms.untracked.vstring(

diff --git a/DQM/EcalMonitorClient/python/EcalDaqInfoTask_cfi.py b/DQM/EcalMonitorClient/python/EcalDaqInfoTask_cfi.py
@@ -1,10 +1,11 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
 from DQM.EcalCommon.CommonParams_cfi import ecalCommonParams
 
 from DQM.EcalMonitorClient.TowerStatusTask_cfi import ecalTowerStatusTask
 
-ecalDaqInfoTask = cms.EDAnalyzer("EcalDQMonitorClient",
+ecalDaqInfoTask = DQMEDHarvester("EcalDQMonitorClient",
     moduleName = cms.untracked.string("Ecal DAQ Monitor"),
     # tasks to be turned on
     workers = cms.untracked.vstring(

diff --git a/DQM/EcalMonitorClient/python/EcalDcsInfoTask_cfi.py b/DQM/EcalMonitorClient/python/EcalDcsInfoTask_cfi.py
@@ -1,10 +1,11 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
 from DQM.EcalCommon.CommonParams_cfi import ecalCommonParams
 
 from DQM.EcalMonitorClient.TowerStatusTask_cfi import ecalTowerStatusTask
 
-ecalDcsInfoTask = cms.EDAnalyzer("EcalDQMonitorClient",
+ecalDcsInfoTask = DQMEDHarvester("EcalDQMonitorClient",
     moduleName = cms.untracked.string("Ecal DCS Monitor"),
     # tasks to be turned on
     workers = cms.untracked.vstring(

diff --git a/DQM/EcalMonitorClient/python/EcalMonitorClient_cfi.py b/DQM/EcalMonitorClient/python/EcalMonitorClient_cfi.py
@@ -1,4 +1,5 @@
 import FWCore.ParameterSet.Config as cms
+from DQMServices.Core.DQMEDHarvester import DQMEDHarvester
 
 from DQM.EcalCommon.CommonParams_cfi import ecalCommonParams
 
@@ -11,7 +12,7 @@
 from DQM.EcalMonitorClient.TrigPrimClient_cfi import ecalTrigPrimClient
 from DQM.EcalMonitorClient.SummaryClient_cfi import ecalSummaryClient
 
-ecalMonitorClient = cms.EDAnalyzer("EcalDQMonitorClient",
+ecalMonitorClient = DQMEDHarvester("EcalDQMonitorClient",
     moduleName = cms.untracked.string("Ecal Monitor Client"),
     # workers to be turned on
     workers = cms.untracked.vstring(