Functions
def	getGoodBRuns
	functions definitions
def	getGoodQRuns
	obtaining list of good quality runs
def	getJSONGoodRuns
	obtain a list of good runs from JSON file
def	getRunRegistryGoodRuns
	obtaining list of good B and quality runs from Run Registry https://twiki.cern.ch/twiki/bin/view/CMS/DqmRrApi https://twiki.cern.ch/twiki/bin/viewauth/CMS/DQMRunRegistry
Variables
string	action = "store_true"
string	allOptions = '### '
string	comma = ","
string	commandline = " "
list	copyargs = sys.argv[:]
string	dbs_quiery = "find run, file.numevents, file where dataset="
	Find files for good runs.
string	default = ''
string	dest = "alcaDataset"
tuple	ff = open('/tmp/runs_and_files_full_of_pink_bunnies','r')
tuple	files_events = zip(list_of_files, list_of_numevents)
tuple	fname = fname.rstrip('\n')
string	help = "[REQUIRED] Name of the input AlCa dataset to get filenames from."
list	infotofile = ["### %s\n" % commandline]
string	jj = ''
list	list_of_files = []
list	list_of_numevents = []
list	list_of_runs = []
int	maxI = 18160
int	minI = 18160
tuple	parser = optparse.OptionParser(usage)
string	rr = ''
list	runs_b_on = []
	get good B field runs from RunInfo DB
list	runs_good = []
	use run registry API is specified
list	runs_good_dq = []
	Add requiremment of good quality runs.
tuple	size = len(list_of_files)
	Write out results.
int	total_numevents = 0
string	type = "string"
tuple	uniq_list_of_runs = list(set(list_of_runs))
tuple	unique_files_events = list(set(files_events))
string	usage = '%prog [options]\n\n'
	To parse commandline args.
	v = options.verbose

Function Documentation

def findQualityFiles::getGoodBRuns ( )

functions definitions

get good B field runs from RunInfo DB

Definition at line 205 of file findQualityFiles.py.

00206                   :
00207 
00208     runs_b_on = []
00209 
00210     sys.setdlopenflags(DLFCN.RTLD_GLOBAL+DLFCN.RTLD_LAZY)
00211 
00212     a = FWIncantation()
00213     #os.putenv("CORAL_AUTH_PATH","/afs/cern.ch/cms/DB/conddb")
00214     rdbms = RDBMS("/afs/cern.ch/cms/DB/conddb")
00215 
00216     db = rdbms.getDB(options.dbName)
00217     tags = db.allTags()
00218 
00219     if options.printTags:
00220         print  "\nOverview of all tags in "+options.dbName+" :\n"
00221         print tags
00222         print "\n"
00223         sys.exit()
00224 
00225     # for inspecting last run after run has started  
00226     #tag = 'runinfo_31X_hlt'
00227     tag = options.dbTag
00228 
00229     # for inspecting last run after run has stopped  
00230     #tag = 'runinfo_test'
00231 
00232     try :
00233         #log = db.lastLogEntry(tag)
00234 
00235         #for printing all log info present into log db 
00236         #print log.getState()
00237 
00238         iov = inspect.Iov(db,tag)
00239         #print "########overview of tag "+tag+"########"
00240         #print iov.list()
00241     
00242         if v>1 :
00243             print "######## summries ########"
00244             for x in  iov.summaries():
00245                 print x[0], x[1], x[2] ,x[3]
00246     
00247         what={}
00248     
00249         if v>1 :
00250             print "###(start_current,stop_current,avg_current,max_current,min_current,run_interval_micros) vs runnumber###"
00251             print iov.trend(what)
00252     
00253         if v>0:
00254             print "######## trends ########"
00255         for x in iov.trendinrange(what,options.startRun-1,options.endRun+1):
00256             if v>0 or x[0]==67647L or x[0]==66893L or x[0]==67264L:
00257                 print x[0],x[1] ,x[2], x[2][4], x[2][3]
00258                 #print x[0],x[1] ,x[2], x[2][4], timeStamptoUTC(x[2][6]), timeStamptoUTC(x[2][7])
00259             if x[2][4] >= minI and x[2][3] <= maxI:
00260                 runs_b_on.append(int(x[0]))
00261 
00262     except Exception, er :
00263         print er
00264 
00265     print "### runs with good B field ###"
00266     print runs_b_on
00267 
00268     return runs_b_on
00269

def findQualityFiles::getGoodQRuns ( )

obtaining list of good quality runs

Definition at line 273 of file findQualityFiles.py.

00274                   :
00275 
00276     runs_good_dq = []
00277 
00278     dbs_quiery = "find run where dataset="+options.dqDataset+" and dq="+options.dqCriteria
00279     print 'dbs search --noheader --query="'+dbs_quiery+'" | sort'
00280 
00281     os.system('python $DBSCMD_HOME/dbsCommandLine.py -c  search --noheader --query="'+dbs_quiery+'" | sort > /tmp/runs_full_of_pink_bunnies')
00282 
00283     #print 'python $DBSCMD_HOME/dbsCommandLine.py -c  search --noheader --query="'+dbs_quiery+'" | sort > /tmp/runs_full_of_pink_bunnies'
00284 
00285     ff = open('/tmp/runs_full_of_pink_bunnies', "r")
00286     line = ff.readline()
00287     while line and line!='':
00288         runs_good_dq.append(int(line))
00289         line = ff.readline()
00290     ff.close()
00291 
00292     os.system('rm /tmp/runs_full_of_pink_bunnies')
00293 
00294     print "### runs with good quality ###"
00295     print runs_good_dq
00296 
00297     return runs_good_dq

def findQualityFiles::getJSONGoodRuns ( )

obtain a list of good runs from JSON file

Definition at line 324 of file findQualityFiles.py.

00325                      :
00326 
00327     # read json file
00328     jsonfile=file(options.json,'r')
00329     jsondict = json.load(jsonfile)
00330 
00331     runs_good = []
00332     for run in jsondict.keys(): runs_good.append(int(run))
00333     runs_good.sort()
00334 
00335     #mruns=[]
00336     #for run in jsondict.keys():
00337     #  if int(run)<144115 and int(run)>136034: mruns.append(int(run))
00338     #mruns.sort()
00339     #print len(mruns),"runs in \n",mruns
00340     
00341     return runs_good

def findQualityFiles::getRunRegistryGoodRuns ( )

obtaining list of good B and quality runs from Run Registry https://twiki.cern.ch/twiki/bin/view/CMS/DqmRrApi https://twiki.cern.ch/twiki/bin/viewauth/CMS/DQMRunRegistry

Definition at line 303 of file findQualityFiles.py.

00304                             :
00305 
00306     server = xmlrpclib.ServerProxy('http://pccmsdqm04.cern.ch/runregistry/xmlrpc')
00307     
00308     rr_quiery = "{runNumber}>="+str(options.startRun)+" and {runNumber}<="+str(options.endRun)+\
00309                 " and {bfield}>="+str(options.minB)+" and {bfield}<="+str(options.maxB)
00310     if options.dqCriteria != "": rr_quiery += " and "+options.dqCriteria
00311     
00312     rrstr = server.RunDatasetTable.export('GLOBAL', 'chart_runs_cum_evs_vs_bfield', rr_quiery)
00313     rrstr = rrstr.replace("bfield","'bfield'")
00314     rrstr = rrstr.replace("events","'events'")
00315     rrdata = eval(rrstr)
00316 
00317     runs_good = []
00318     for rr in rrdata['events']: runs_good.append(rr[0])
00319 
00320     return runs_good