Skip to content

Commit

Permalink
Further improvements of the DQM clients for condition access.
Browse files Browse the repository at this point in the history
  • Loading branch information
Salvatore Di Guida authored and cmsdqm committed Feb 19, 2016
1 parent 75800d9 commit 0f44709
Show file tree
Hide file tree
Showing 7 changed files with 40 additions and 220 deletions.
133 changes: 29 additions & 104 deletions DQM/Integration/python/clients/castor_dqm_sourceclient-live_cfg.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,113 +27,38 @@
#============================================
# Castor Conditions: from Global Conditions Tag
#============================================
process.load("CondCore.DBCommon.CondDBSetup_cfi")
process.load("CondCore.DBCommon.CondDBCommon_cfi")
process.load('Configuration.StandardSequences.CondDBESSource_cff')
#FIXME: they should use an official GT, not define custom records and conditions on their own!!!
process.GlobalTag.toGet = cms.VPSet( cms.PSet( record = cms.string('CastorGainsRcd'),
tag = cms.string('CastorGains_v2.1_hlt'),
),
cms.PSet( record = cms.string('CastorSaturationCorrsRcd'),
tag = cms.string('CastorSaturationCorrs_v3.00_offline'),
),
cms.PSet( record = cms.string('CastorPedestalWidthsRcd'),
tag = cms.string('CastorPedestalWidths_v3.00_offline'),
),
cms.PSet( record = cms.string('CastorGainWidthsRcd'),
tag = cms.string('CastorGainWidths_v3.00_offline'),
),
cms.PSet( record = cms.string('CastorQIEDataRcd'),
tag = cms.string('CastorQIEData_v3.00_offline'),
),
cms.PSet( record = cms.string('CastorChannelQualityRcd'),
tag = cms.string('CastorChannelQuality_v3.00_offline'),
),
cms.PSet( record = cms.string('CastorElectronicsMapRcd'),
tag = cms.string('CastorElectronicsMap_v3.00_offline'),

This comment has been minimized.

Copy link
@franzoni

franzoni Nov 8, 2016

what is this???
How are we now supposed to get the castor people the modifications they need for their online DQM.
I am blushing.

),
)

process.CastorDbProducer = cms.ESProducer("CastorDbProducer")

###process.es_pool = cms.ESSource(
### "PoolDBESSource",
### process.CondDBSetup,
### timetype = cms.string('runnumber'),
### connect = cms.string('frontier://(proxyurl=http://localhost:3128)(serverurl=http://localhost:8000/FrontierOnProd)(serverurl=http://localhost:8000/FrontierOn Prod)(retrieve-ziplevel=0)(failovertoserver=no)/CMS_COND_31X_HCAL'),
### authenticationMethod = cms.untracked.uint32(0),
### toGet = cms.VPSet(
### cms.PSet(
### record = cms.string('CastorPedestalsRcd'),
### tag = cms.string('castor_pedestals_v1.0')
### ),
### cms.PSet(
### record = cms.string('CastorPedestalWidthsRcd'),
### tag = cms.string('castor_pedestalwidths_v1.0')
### ),
### cms.PSet(
### record = cms.string('CastorGainsRcd'),
### tag = cms.string('castor_gains_v1.0')
### ),
### cms.PSet(
### record = cms.string('CastorGainWidthsRcd'),
### tag = cms.string('castor_gainwidths_v1.0')
### ),
### cms.PSet(
### record = cms.string('CastorQIEDataRcd'),
### tag = cms.string('castor_qie_v1.0')
### ),
### cms.PSet(
### record = cms.string('CastorChannelQualityRcd'),
### tag = cms.string('castor_channelquality_v1.0')
### ),
### cms.PSet(
### record = cms.string('CastorElectronicsMapRcd'),
### tag = cms.string('castor_emap_dcc_v1.0')
### )
### )
###)

process.es_pool0 = cms.ESSource(
"PoolDBESSource",
process.CondDBSetup,
timetype = cms.string('runnumber'),
###connect = cms.string('frontier://FrontierProd/CMS_COND_31X_HCAL'),
connect = cms.string('frontier://(proxyurl=http://localhost:3128)(serverurl=http://localhost:8000/FrontierOnProd)(serverurl=http://localhost:8000/FrontierOn Prod)(retrieve-ziplevel=0)(failovertoserver=no)/CMS_COND_31X_HCAL'),
authenticationMethod = cms.untracked.uint32(0),
toGet = cms.VPSet(
cms.PSet(
record = cms.string('CastorGainsRcd'),
tag = cms.string('CastorGains_v2.1_hlt') #all gains=1, corresponding to GR_P_V43D and CastorGains_v2.1_hlt in frontier://PromptProd/CMS_COND_31X_HCAL
)
)
)

process.es_pool = cms.ESSource(
"PoolDBESSource",
process.CondDBSetup,
timetype = cms.string('runnumber'),
#connect = cms.string('frontier://cmsfrontier.cern.ch:8000/FrontierPrep/CMS_COND_30X_HCAL'),
#connect = cms.string('frontier://cmsfrontier.cern.ch:8000/FrontierProd/CMS_COND_31X_HCAL'),
###connect = cms.string('frontier://FrontierProd/CMS_COND_HCAL_000'),
connect = cms.string('frontier://(proxyurl=http://localhost:3128)(serverurl=http://localhost:8000/FrontierOnProd)(serverurl=http://localhost:8000/FrontierOn Prod)(retrieve-ziplevel=0)(failovertoserver=no)/CMS_COND_HCAL_000'),
authenticationMethod = cms.untracked.uint32(0),
toGet = cms.VPSet(
cms.PSet(
record = cms.string('CastorSaturationCorrsRcd'),
tag = cms.string('CastorSaturationCorrs_v3.00_offline')
),
#
cms.PSet(
record = cms.string('CastorPedestalsRcd'),
tag = cms.string('CastorPedestals_v3.00_offline')
),
#
cms.PSet(
record = cms.string('CastorPedestalWidthsRcd'),
tag = cms.string('CastorPedestalWidths_v3.00_offline')
),
#
# cms.PSet(
# record = cms.string('CastorGainsRcd'),
# tag = cms.string('CastorGains_v3.00_offline')
# ),
#
cms.PSet(
record = cms.string('CastorGainWidthsRcd'),
tag = cms.string('CastorGainWidths_v3.00_offline')
),
cms.PSet(
record = cms.string('CastorQIEDataRcd'),
tag = cms.string('CastorQIEData_v3.00_offline')
),
cms.PSet(
record = cms.string('CastorChannelQualityRcd'),
tag = cms.string('CastorChannelQuality_v3.00_offline')
),
cms.PSet(
record = cms.string('CastorElectronicsMapRcd'),
tag = cms.string('CastorElectronicsMap_v3.00_offline')
)
)
)

##most likely the real fix:
#process.load("DQM.Integration.config.FrontierCondition_GT_cfi")
## Condition for lxplus: change and possibly customise the GT
#from Configuration.AlCa.GlobalTag import GlobalTag as gtCustomise
#process.GlobalTag = gtCustomise(process.GlobalTag, 'auto:run2_data', '')

#-----------------------------
# Castor DQM Source + SimpleReconstrctor
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -125,12 +125,10 @@
process.GlobalTag.toGet = cms.VPSet(cms.PSet(
record = cms.string('EcalDQMChannelStatusRcd'),
tag = cms.string('EcalDQMChannelStatus_v1_hlt'),
connect = cms.string('frontier://(proxyurl=http://frontier.cms:3128)(serverurl=http://frontier.cms:8000/FrontierOnProd)(serverurl=http://frontier.cms:8000/FrontierOnProd)(retrieve-ziplevel=0)(failovertoserver=no)/CMS_COND_34X_ECAL')
),
cms.PSet(
record = cms.string('EcalDQMTowerStatusRcd'),
tag = cms.string('EcalDQMTowerStatus_v1_hlt'),
connect = cms.string('frontier://(proxyurl=http://frontier.cms:3128)(serverurl=http://frontier.cms:8000/FrontierOnProd)(serverurl=http://frontier.cms:8000/FrontierOnProd)(retrieve-ziplevel=0)(failovertoserver=no)/CMS_COND_34X_ECAL')
))

process.preScaler.prescaleFactor = 1
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -170,12 +170,10 @@
process.GlobalTag.toGet = cms.VPSet(cms.PSet(
record = cms.string('EcalDQMChannelStatusRcd'),
tag = cms.string('EcalDQMChannelStatus_v1_hlt'),
connect = cms.string('frontier://(proxyurl=http://frontier.cms:3128)(serverurl=http://frontier.cms:8000/FrontierOnProd)(serverurl=http://frontier.cms:8000/FrontierOnProd)(retrieve-ziplevel=0)(failovertoserver=no)/CMS_COND_34X_ECAL')
),
cms.PSet(
record = cms.string('EcalDQMTowerStatusRcd'),
tag = cms.string('EcalDQMTowerStatus_v1_hlt'),
connect = cms.string('frontier://(proxyurl=http://frontier.cms:3128)(serverurl=http://frontier.cms:8000/FrontierOnProd)(serverurl=http://frontier.cms:8000/FrontierOnProd)(retrieve-ziplevel=0)(failovertoserver=no)/CMS_COND_34X_ECAL')
))

process.ecalTestPulseMonitorTask.verbosity = 0
Expand Down
23 changes: 4 additions & 19 deletions DQM/Integration/python/clients/hcal_dqm_sourceclient-live_cfg.py
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,6 @@
process.load("EventFilter.HcalRawToDigi.HcalRawToDigi_cfi")
process.load("RecoLocalCalo.Configuration.hcalLocalReco_cff")
process.load("SimCalorimetry.HcalTrigPrimProducers.hcaltpdigi_cff")
process.load("CondCore.DBCommon.CondDBSetup_cfi")
process.load("L1Trigger.Configuration.L1DummyConfig_cff")
process.load("EventFilter.L1GlobalTriggerRawToDigi.l1GtUnpack_cfi")

Expand Down Expand Up @@ -114,24 +113,10 @@
# Will not be here for Online DQM
#-------------------------------------
if useMap:
process.es_pool = cms.ESSource("PoolDBESSource",
process.CondDBSetup,
timetype = cms.string('runnumber'),
toGet = cms.VPSet(
cms.PSet(
record = cms.string(
"HcalElectronicsMapRcd"
),
tag = cms.string(
"HcalElectronicsMap_v7.05_hlt"
)
)
),
connect = cms.string(
'frontier://FrontierProd/CMS_CONDITIONS'),
authenticationMethod = cms.untracked.uint32(0)
)
process.es_prefer_es_pool = cms.ESPrefer('PoolDBESSource', 'es_pool')
process.GlobalTag.toGet.append(cms.PSet(record = cms.string("HcalElectronicsMapRcd"),
tag = cms.string("HcalElectronicsMap_v7.05_hlt"),
)
)

#-------------------------------------
# For Debugginb
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,6 @@
process.load("EventFilter.HcalRawToDigi.HcalRawToDigi_cfi")
process.load("RecoLocalCalo.Configuration.hcalLocalReco_cff")
process.load("SimCalorimetry.HcalTrigPrimProducers.hcaltpdigi_cff")
process.load("CondCore.DBCommon.CondDBSetup_cfi")
process.load("L1Trigger.Configuration.L1DummyConfig_cff")
process.load("EventFilter.L1GlobalTriggerRawToDigi.l1GtUnpack_cfi")

Expand Down Expand Up @@ -108,24 +107,10 @@
# Absent for Online Running
#-------------------------------------
if useMap:
process.es_pool = cms.ESSource("PoolDBESSource",
process.CondDBSetup,
timetype = cms.string('runnumber'),
toGet = cms.VPSet(
cms.PSet(
record = cms.string(
"HcalElectronicsMapRcd"
),
tag = cms.string(
"HcalElectronicsMap_v7.05_hlt"
)
)
),
connect = cms.string(
'frontier://FrontierProd/CMS_CONDITIONS'),
authenticationMethod = cms.untracked.uint32(0)
)
process.es_prefer_es_pool = cms.ESPrefer('PoolDBESSource', 'es_pool')
process.GlobalTag.toGet.append(cms.PSet(record = cms.string("HcalElectronicsMapRcd"),
tag = cms.string("HcalElectronicsMap_v7.05_hlt"),
)
)

#-------------------------------------
# For Debugginb
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -26,16 +26,15 @@
#process.load("Geometry.MuonNumbering.muonNumberingInitialization_cfi")
process.load("Configuration.StandardSequences.GeometryRecoDB_cff")
################ Condition ######################
process.load("CondCore.DBCommon.CondDBSetup_cfi")

############# DQM Cetral Modules ################
#process.load("DQMServices.Core.DQM_cfg")
# Condition for P5 cluster
process.load("DQM.Integration.config.FrontierCondition_GT_cfi")
# Condition for lxplus
#process.load("DQM.Integration.config.FrontierCondition_GT_Offline_cfi")
process.GlobalTag.RefreshEachRun = cms.untracked.bool(True)

############# DQM Cetral Modules ################
#process.load("DQMServices.Core.DQM_cfg")

############## DQM Enviroment ###################
process.load("DQM.Integration.config.environment_cfi")
process.dqmEnv.subSystemFolder = 'RPC'
Expand Down

0 comments on commit 0f44709

Please sign in to comment.