findQualityFiles Namespace Reference

Functions
def	getGoodBRuns
	functions definitions More...
def	getGoodQRuns
	obtaining list of good quality runs More...
def	getJSONGoodRuns
	obtain a list of good runs from JSON file More...
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 More...

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. More...
string	default = ''
string	dest = "alcaDataset"
tuple	ff = open('/tmp/runs_and_files_full_of_pink_bunnies','r')
tuple	files_events = list(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 = options.maxB*18160
int	minI = options.minB*18160
tuple	parser = optparse.OptionParser(usage)
string	rr = ''
list	runs_b_on = []
	get good B field runs from RunInfo DB More...
list	runs_good = []
	use run registry API is specified More...
list	runs_good_dq = []
	Add requiremment of good quality runs. More...
tuple	size = len(list_of_files)
	Write out results. More...
int	total_numevents = 0
string	type = "string"
tuple	uniq_list_of_runs = sorted(set(list_of_runs))
tuple	unique_files_events = list(set(files_events))
string	usage = '%prog [options]\n\n'
	To parse commandline args. More...
	v = options.verbose

Function Documentation

def findQualityFiles.getGoodBRuns

(

)

functions definitions

get good B field runs from RunInfo DB

Definition at line 207 of file findQualityFiles.py.

References print().

def getGoodBRuns():

    runs_b_on = []

    sys.setdlopenflags(DLFCN.RTLD_GLOBAL+DLFCN.RTLD_LAZY)

    a = FWIncantation()
    #os.putenv("CORAL_AUTH_PATH","/afs/cern.ch/cms/DB/conddb")
    rdbms = RDBMS("/afs/cern.ch/cms/DB/conddb")

    db = rdbms.getDB(options.dbName)
    tags = db.allTags()

    if options.printTags:
        print("\nOverview of all tags in "+options.dbName+" :\n")
        print(tags)
        print("\n")
        sys.exit()

    # for inspecting last run after run has started  
    #tag = 'runinfo_31X_hlt'
    tag = options.dbTag

    # for inspecting last run after run has stopped  
    #tag = 'runinfo_test'

    try :
        #log = db.lastLogEntry(tag)

        #for printing all log info present into log db 
        #print log.getState()

        iov = inspect.Iov(db,tag)
        #print "########overview of tag "+tag+"########"
        #print iov.list()
    
        if v>1 :
            print("######## summries ########")
            for x in  iov.summaries():
                print(x[0], x[1], x[2] ,x[3])
    
        what={}
    
        if v>1 :
            print("###(start_current,stop_current,avg_current,max_current,min_current,run_interval_micros) vs runnumber###")
            print(iov.trend(what))
    
        if v>0:
            print("######## trends ########")
        for x in iov.trendinrange(what,options.startRun-1,options.endRun+1):
            if v>0 or x[0]==67647 or x[0]==66893 or x[0]==67264:
                print(x[0],x[1] ,x[2], x[2][4], x[2][3])
                #print x[0],x[1] ,x[2], x[2][4], timeStamptoUTC(x[2][6]), timeStamptoUTC(x[2][7])
            if x[2][4] >= minI and x[2][3] <= maxI:
                runs_b_on.append(int(x[0]))

    except Exception as er :
        print(er)

    print("### runs with good B field ###")
    print(runs_b_on)

    return runs_b_on