Functions
	copyfunc (indb, outdb, func_iov, func_output, runends)
	truncate_iovs_to_runs (iovs, runends)
	get_runends ()
	dq_code_filter (foldername, tag, channel, codes)
	defect_output (channel)
	atlas_notready_filter (indb)

Variables
list	TRIPLES
	runends = get_runends()
	outdb = DefectsDB('defectstest.db/COMP200', read_only=False)

Function Documentation

◆ atlas_notready_filter()

dq_defect_translate_defects.atlas_notready_filter ( indb )

Definition at line 57 of file dq_defect_translate_defects.py.

def atlas_notready_filter(indb):
    from DQUtils.db import fetch_iovs
    folder = indb.getFolder('/TDAQ/RunCtrl/DataTakingMode')
    iovs = fetch_iovs(folder, channels=[0])
            
    return filter(None, [iov for iov in iovs if iov.ReadyForPhysics == 0])
 

◆ copyfunc()

dq_defect_translate_defects.copyfunc	(	indb,
		outdb,
		func_iov,
		func_output,
		runends )

indb = input database
outdb = output database
func_iov = function that takes a DB connection and returns some IOVs
           (includes folder/channel selection and any filtering)
func_output = takes IOVs and writes them to the output DB connection

Definition at line 3 of file dq_defect_translate_defects.py.

def copyfunc(indb, outdb, func_iov, func_output, runends):
    '''
    indb = input database
    outdb = output database
    func_iov = function that takes a DB connection and returns some IOVs
               (includes folder/channel selection and any filtering)
    func_output = takes IOVs and writes them to the output DB connection
    '''
    iovs = func_iov(indb)
    iovs = truncate_iovs_to_runs(iovs, runends)
    iovs = filter(lambda x: not(x.until.lumi-x.since.lumi == 0), iovs)
    print('There are %d IOVs to process' % len(iovs))
    
    for i, iov in enumerate(iovs):
        func_output(outdb, iov)
        if i % 100 == 1:
            print('IOV', i)
 

◆ defect_output()

dq_defect_translate_defects.defect_output ( channel )

Definition at line 49 of file dq_defect_translate_defects.py.

def defect_output(channel):
    def defect_output_internals(outdb, iov):
        db = outdb
        db.insert(channel, iov.since, iov.until,
                  (iov.Comment if 'Comment' in dir(iov) else 'Automatic'),
                  'sys:copy')
    return defect_output_internals
 

◆ dq_code_filter()

dq_defect_translate_defects.dq_code_filter	(	foldername,
		tag,
		channel,
		codes )

Definition at line 40 of file dq_defect_translate_defects.py.

def dq_code_filter(foldername, tag, channel, codes):
    from DQUtils.db import fetch_iovs
    def dq_code_filter_internals(indb):
        folder = indb.getFolder(foldername)
        iovs = fetch_iovs(folder, channels=[channel], tag=tag)
        iovs = [iov for iov in iovs if iov.Code in codes]
        return iovs
    return dq_code_filter_internals
 

◆ get_runends()

dq_defect_translate_defects.get_runends ( )

Definition at line 31 of file dq_defect_translate_defects.py.

def get_runends():
    from DQUtils.db import fetch_iovs
    eor_params = fetch_iovs('EOR_Params', 
                             with_channel=False, what=[])
    runends = {}
    for iov in eor_params:
        runends[iov.since.run] = iov
    return runends
 

◆ truncate_iovs_to_runs()

dq_defect_translate_defects.truncate_iovs_to_runs	(		iovs,
			runends )

Definition at line 22 of file dq_defect_translate_defects.py.

def truncate_iovs_to_runs(iovs, runends):
    for iov in iovs:
        if iov.since.run not in runends:
            print('Missing run', iov.since.run, 'from EOR_Params')
            
    return filter(None,
                  [iov.intersect(runends[iov.since.run])
                   for iov in iovs if iov.since.run in runends])
   

Variable Documentation

◆ outdb

dq_defect_translate_defects.outdb = DefectsDB('defectstest.db/COMP200', read_only=False)

Definition at line 157 of file dq_defect_translate_defects.py.

◆ runends

dq_defect_translate_defects.runends = get_runends()

Definition at line 156 of file dq_defect_translate_defects.py.

◆ TRIPLES

list dq_defect_translate_defects.TRIPLES

Definition at line 68 of file dq_defect_translate_defects.py.

Functions

Variables