Functions
def	dasQuery (queryString, entryTitle)

def	dasRunQueryToDict (querystring)

def	day (string)

def	daysAgo (n)

def	getFilesForRun (run, dataset)

def	getRunsForDate (date, minlumis=10)

def	getRunsNewer (run, minlumis=10, source='RunRegistry')

def	runGetDatasetsAvailable (run)

def	today ()

Function Documentation

◆ dasQuery()

def util.getRunInfo.dasQuery	(	queryString,
		entryTitle
	)

Definition at line 74 of file getRunInfo.py.

References das_client.get_data().

Referenced by util.getRunInfo.dasRunQueryToDict(), util.getRunInfo.getFilesForRun(), and util.getRunInfo.runGetDatasetsAvailable().

 def dasQuery(queryString, entryTitle) :
     dasinfo = das_client.get_data('https://cmsweb.cern.ch', queryString, 0, 0, False)
     if dasinfo['status'] != 'ok' :
         raise Exception('DAS query failed.\nQuery: %s\nDAS Status returned: %s' % (queryString, dasinfo['status']))
 
     if len(dasinfo['data']) > 0 :
         for entry in dasinfo['data'] :
             if entryTitle in entry and len(entry[entryTitle]) > 0 :
                 yield entry[entryTitle][0]

◆ dasRunQueryToDict()

def util.getRunInfo.dasRunQueryToDict ( querystring )

Definition at line 66 of file getRunInfo.py.

References util.getRunInfo.dasQuery(), and createfilelist.int.

Referenced by util.getRunInfo.getRunsForDate(), and util.getRunInfo.getRunsNewer().

 def dasRunQueryToDict(querystring) :
     runs = {}
     for runDict in dasQuery(querystring, 'run') :
         runNo = int(runDict['run_number'])
         runDict['date'] = datestring
         runs[runNo] = runDict
     return runs
 

◆ day()

def util.getRunInfo.day ( string )

Definition at line 11 of file getRunInfo.py.

Referenced by RunDCSHVDat.fillTheMapByTime(), LMFRunIOV.getParameters(), LMFLmrSubIOV.getParameters(), CSCTFConfigOnlineProd.newObject(), RunSummaryRead.readData(), L1TriggerScalerRead.readData(), SiStripDetVOffBuilder.readLastValueFromFile(), and RPCFw.UTtoT().

 def day(string) :
     return datetime.datetime.strptime(string, "%Y%m%d").date()
 

◆ daysAgo()

def util.getRunInfo.daysAgo ( n )

Definition at line 7 of file getRunInfo.py.

References util.getRunInfo.today().

 def daysAgo(n) :
     date = today()
     return date - datetime.timedelta(days=n)
 

◆ getFilesForRun()

def util.getRunInfo.getFilesForRun	(	run,
		dataset
	)

    run : int
    dataset : string dataset to find files in, e.g.
        /ExpressCosmics/Run2015A-Express-v1/FEVT
        /ExpressPhysics/Run2015A-Express-v1/FEVT

Definition at line 47 of file getRunInfo.py.

References util.getRunInfo.dasQuery(), and alcaDQMUpload.encode().

 def getFilesForRun(run, dataset) :
     '''
         run : int
         dataset : string dataset to find files in, e.g.
             /ExpressCosmics/Run2015A-Express-v1/FEVT
             /ExpressPhysics/Run2015A-Express-v1/FEVT
     '''
     querystring = "file dataset={dataset} run={run}".format(dataset=dataset, run=run)
 
     files = []
     for fileDict in dasQuery(querystring, 'file') :
         # cmsRun will not like unicode
         files.append(fileDict['name'].encode('ascii','replace'))
 
     return files
 
 
 # -------------------- DAS convert tools
 

◆ getRunsForDate()

def util.getRunInfo.getRunsForDate	(	date,
		minlumis = `10`
	)

    date: expected to be datetime.datetime object

Definition at line 14 of file getRunInfo.py.

References util.getRunInfo.dasRunQueryToDict().

 def getRunsForDate(date, minlumis=10) :
     '''
         date: expected to be datetime.datetime object
     '''
     datestring = date.strftime('%Y%m%d')
     querystring = "run date={date} | grep run.nlumis>{minlumis}".format(date=datestring, minlumis=minlumis)
     return dasRunQueryToDict(querystring)
 

◆ getRunsNewer()

def util.getRunInfo.getRunsNewer	(	run,
		minlumis = `10`,
		source = `'RunRegistry'`
	)

    run: run number int
    source: Either RunRegistry or DAS

Definition at line 22 of file getRunInfo.py.

References util.getRunInfo.dasRunQueryToDict().

 def getRunsNewer(run, minlumis=10, source='RunRegistry') :
     '''
         run: run number int
         source: Either RunRegistry or DAS
     '''
     if source == 'RunRegistry' :
         return rrClient.getRunsNewer(run, minlumis)
     elif source == 'DAS' :
         querystring = "run | grep run.nlumis>{minlumis}, run.runnumber>{run}".format(run=run, minlumis=minlumis)
         return dasRunQueryToDict(querystring)
 

◆ runGetDatasetsAvailable()

def util.getRunInfo.runGetDatasetsAvailable ( run )

    run : int
    Will return a list of datasets in DAS that have the run in them

Definition at line 33 of file getRunInfo.py.

References util.getRunInfo.dasQuery(), and alcaDQMUpload.encode().

 def runGetDatasetsAvailable(run) :
     '''
         run : int
         Will return a list of datasets in DAS that have the run in them
     '''
     querystring = "dataset run={run}".format(run=run)
 
     datasets = []
     for datasetDict in dasQuery(querystring, 'dataset') :
         # cmsRun will not like unicode
         datasets.append(datasetDict['name'].encode('ascii','replace'))
 
     return datasets
 

◆ today()

def util.getRunInfo.today ( )

Definition at line 4 of file getRunInfo.py.

Referenced by util.getRunInfo.daysAgo().

 def today() :
     return datetime.datetime.now().date()
 

Functions