CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
Functions | Variables
run_AlCaRecoTriggerBitsUpdateWorkflow Namespace Reference

Functions

def get_iovs
 
def getCommandOutput
 
def main
 
def updateBits
 

Variables

string action = "store_true"
 
tuple child = os.popen(command)
 
string cleanCommand = 'rm -fr *updated*.db *IOV_*.db'
 
string cmsRunCommand
 
string command = 'conddb --yes --db %s copy %s --destdb %s --from %s --to %s'
 
tuple con = conddb.connect(url = conddb.make_url(db))
 
tuple count = pool.map(updateBits,myInputTuple)
 
tuple data = child.read()
 
list db = officialdbs[db]
 unfortunately some gymnastics is needed here to make use of the conddb library More...
 
 db_url = options.inputDB
 allow to use input sqlite files as well More...
 
 default = defaultDB,
 
string defaultDB = 'sqlite_file:mySqlite.db'
 
string defaultInTag = 'myInTag'
 
string defaultOutTag = 'myOutTag'
 
int defaultProc = 20
 
string dest = 'inputDB'
 
tuple err = child.close()
 
string help = 'file to inspect'
 
tuple IOV = session.get_dbtype(conddb.IOV)
 
tuple iovs = set(session.query(IOV.since).filter(IOV.tag_name == tag).all())
 
string mergeCommand = 'conddb --yes --db %s copy %s --destdb %s --from %s'
 
list myInputTuple = []
 
dictionary officialdbs
 
tuple parser = optparse.OptionParser(usage = 'Usage: %prog [options] <file> [<file> ...]\n')
 
tuple pool = multiprocessing.Pool(processes=options.nproc)
 
tuple session = con.session()
 
tuple sinces = get_iovs(options.inputDB,options.InputTag)
 

Function Documentation

def run_AlCaRecoTriggerBitsUpdateWorkflow.get_iovs (   db,
  tag 
)
def run_AlCaRecoTriggerBitsUpdateWorkflow.getCommandOutput (   command)

Definition at line 24 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

References print().

24 
def getCommandOutput(command):
def run_AlCaRecoTriggerBitsUpdateWorkflow.main ( )

Definition at line 97 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

97 
def main():
def run_AlCaRecoTriggerBitsUpdateWorkflow.updateBits (   blob)

Definition at line 70 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

References if().

70 
def updateBits(blob):

Variable Documentation

string run_AlCaRecoTriggerBitsUpdateWorkflow.action = "store_true"

Definition at line 124 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.child = os.popen(command)
This function executes `command` and returns it output.
Arguments:
- `command`: Shell command to be invoked by this function.

Definition at line 31 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

string run_AlCaRecoTriggerBitsUpdateWorkflow.cleanCommand = 'rm -fr *updated*.db *IOV_*.db'

Definition at line 163 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

string run_AlCaRecoTriggerBitsUpdateWorkflow.cmsRunCommand
Initial value:
1 = 'cmsRun $CMSSW_BASE/src/CondTools/HLT/test/AlCaRecoTriggerBitsRcdUpdate_TEMPL_cfg.py \
2  inputDB=%s inputTag=%s outputDB=%s outputTag=%s firstRun=%s'

Definition at line 88 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

string run_AlCaRecoTriggerBitsUpdateWorkflow.command = 'conddb --yes --db %s copy %s --destdb %s --from %s --to %s'

Definition at line 73 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.con = conddb.connect(url = conddb.make_url(db))

Definition at line 56 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

Referenced by AlCaGammaJetProducer.produce().

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.count = pool.map(updateBits,myInputTuple)

Definition at line 151 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.data = child.read()

Definition at line 32 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.db = officialdbs[db]

unfortunately some gymnastics is needed here to make use of the conddb library

allow to use input sqlite files as well

Retrieve the list of IOVs from `db` for `tag`.

Arguments:
- `db`: database connection string
- `tag`: tag of database record

Definition at line 51 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.db_url = options.inputDB

allow to use input sqlite files as well

Definition at line 130 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

run_AlCaRecoTriggerBitsUpdateWorkflow.default = defaultDB,

Definition at line 108 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

string run_AlCaRecoTriggerBitsUpdateWorkflow.defaultDB = 'sqlite_file:mySqlite.db'

Definition at line 100 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

string run_AlCaRecoTriggerBitsUpdateWorkflow.defaultInTag = 'myInTag'

Definition at line 101 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

string run_AlCaRecoTriggerBitsUpdateWorkflow.defaultOutTag = 'myOutTag'

Definition at line 102 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

int run_AlCaRecoTriggerBitsUpdateWorkflow.defaultProc = 20

Definition at line 103 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

string run_AlCaRecoTriggerBitsUpdateWorkflow.dest = 'inputDB'

Definition at line 107 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.err = child.close()

Definition at line 33 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

string run_AlCaRecoTriggerBitsUpdateWorkflow.help = 'file to inspect'

Definition at line 109 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.IOV = session.get_dbtype(conddb.IOV)

Definition at line 58 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

Referenced by checkrunlist(), models.generate(), HIPplots.HIPplots(), and publishObjects().

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.iovs = set(session.query(IOV.since).filter(IOV.tag_name == tag).all())

Definition at line 60 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

Referenced by SiStripDetVOffTkMapPlotter.analyze(), SiStripDetVOffPrinter.analyze(), SiStripDetVOffTrendPlotter.analyze(), BeamSpotRcdPrinter.analyze(), cond::persistency.copyIov(), cond::persistency::IOV::Table.eraseMany(), cond::payloadInspector::PlotImpl< UNSPECIFIED_IOV, 0 >.fill(), cond::payloadInspector::PlotImpl< UNSPECIFIED_IOV, 1 >.fill(), BeamSpotPI::DisplayParametersDiff< PayloadType, nIOVs, ntags >.fill(), gainCalibHelper::SiPixelGainCalibrationValuesComparisonPerRegion< isBarrel, myType, nIOVs, ntags, PayloadType >.fill(), gainCalibHelper::SiPixelGainCalibrationValueComparisonBase< myType, PayloadType >.fill(), gainCalibHelper::SiPixelGainCalibDiffAndRatioBase< myType, nIOVs, ntags, PayloadType >.fill(), gainCalibHelper::SiPixelGainCalibrationByRegionComparisonBase< myType, PayloadType, nIOVs, ntags >.fill(), models.generate(), cond::persistency::IOV::Table.getRange(), RunInfoUpdate.import(), cond::persistency.importIovs(), cond::persistency::IOV::Table.insertMany(), l1t::DataWriter.payloadToken(), l1t::DataWriterExt.payloadToken(), cond::persistency::IOV::Table.select(), and popcon::PopCon.write().

string run_AlCaRecoTriggerBitsUpdateWorkflow.mergeCommand = 'conddb --yes --db %s copy %s --destdb %s --from %s'

Definition at line 155 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

list run_AlCaRecoTriggerBitsUpdateWorkflow.myInputTuple = []

Definition at line 141 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

dictionary run_AlCaRecoTriggerBitsUpdateWorkflow.officialdbs
Initial value:
1 = {
2  # frontier connections
3  'frontier://PromptProd/CMS_CONDITIONS' :'pro',
4  'frontier://FrontierProd/CMS_CONDITIONS' :'pro',
5  'frontier://FrontierArc/CMS_CONDITIONS' :'arc',
6  'frontier://FrontierInt/CMS_CONDITIONS' :'int',
7  'frontier://FrontierPrep/CMS_CONDITIONS' :'dev'
8 }

Definition at line 14 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.parser = optparse.OptionParser(usage = 'Usage: %prog [options] <file> [<file> ...]\n')

Definition at line 105 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.pool = multiprocessing.Pool(processes=options.nproc)

Definition at line 150 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.session = con.session()

Definition at line 57 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.

Referenced by LumiProducer.beginRun(), popcon::PopConBTransitionSourceHandler< T >.checkBOn(), popcon::PopConESTransitionSourceHandler< T >.checkLowGain(), tensorflow.closeSession(), RPCDBCom.connect(), TestBase.connect(), popcon::L1RPCHwConfigSourceHandler.ConnectOnlineDB(), popcon::RPCEMapSourceHandler.ConnectOnlineDB(), RPCFw.createFEB(), RPCFw.createGAS(), RPCFw.createIDMAP(), RPCFw.createIMON(), RPCFw.createMix(), cond::CredentialStore.createSchema(), tensorflow.createSession(), RPCFw.createSTATUS(), RPCFw.createT(), RPCFw.createUXC(), RPCFw.createVMON(), popcon::L1RPCHwConfigSourceHandler.DisconnectOnlineDB(), popcon::RPCEMapSourceHandler.DisconnectOnlineDB(), DTOccupancyTestML.dqmEndLuminosityBlock(), cond::CredentialStore.drop(), L1TriggerScalerRead.dropTable(), GEDPhotonProducer.endStream(), GsfElectronProducer.endStream(), cond::CredentialStore.exportAll(), DIPLumiProducer.filldetailcache(), ExpressLumiProducer.fillLSCache(), LumiProducer.fillLSCache(), LumiCorrectionSource.fillparamcache(), DIPLumiProducer.fillsummarycache(), CondDBESSource.fillTagCollectionFromGT(), BeamSpotOnlinePopConSourceHandler.getNewObjects(), FillInfoPopConSourceHandler.getNewObjects(), LHCInfoPopConSourceHandler.getNewObjects(), popcon::PopConBTransitionSourceHandler< T >.getObjectsForBTransition(), popcon::PopConESTransitionSourceHandler< T >.getObjectsForESTransition(), cond::CredentialStore.getUserCredentials(), cond::CredentialStore.importForPrincipal(), cond::CredentialStore.listConnections(), cond::CredentialStore.listPrincipals(), l1t::DataWriter.payloadToken(), l1t::DataWriterExt.payloadToken(), cond::service::OnlineDBOutputService.preLoadIov(), L1RCTOmdsFedVectorProducer.produce(), ecaldqm::MLClient.producePlots(), RunInfoRead.readData(), DQMSummaryReader.readData(), RunSummaryRead.readData(), L1TriggerScalerRead.readData(), popcon::RPCEMapSourceHandler.readEMap1(), popcon::L1RPCHwConfigSourceHandler.readHwConfig1(), l1t::DataWriter.readObject(), l1t::DataWriterExt.readObject(), cond::CredentialStore.removeConnection(), cond::CredentialStore.removePrincipal(), cond::CredentialStore.resetAdmin(), lumi::CMSRunSummaryDummy2DB.retrieveData(), lumi::HLTDummy2DB.retrieveData(), lumi::HLTConfDummy2DB.retrieveData(), lumi::TRGDummy2DB.retrieveData(), lumi::LumiDummy2DB.retrieveData(), lumi::Lumi2DB.retrieveData(), l1t::WriterProxyT< Record, Type >.save(), cond::CredentialStore.selectForUser(), cond::CredentialStore.selectPermissions(), cond::CredentialStore.setPermission(), cond::CredentialStore.unsetPermission(), cond::CredentialStore.updateConnection(), cond::CredentialStore.updatePrincipal(), l1t::DataWriter.writeKeyList(), and l1t::DataWriterExt.writeKeyList().

tuple run_AlCaRecoTriggerBitsUpdateWorkflow.sinces = get_iovs(options.inputDB,options.InputTag)

Definition at line 137 of file run_AlCaRecoTriggerBitsUpdateWorkflow.py.