Functions
def	copyfunc (indb, outdb, func_iov, func_output, runends)

def	truncate_iovs_to_runs (iovs, runends)

def	get_runends ()

def	dq_code_filter (foldername, tag, channel, codes)

def	defect_output (channel)

def	atlas_notready_filter (indb)

Variables
list	TRIPLES

def	runends = get_runends()

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

Function Documentation

◆ atlas_notready_filter()

def 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()

def 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()

def 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()

def 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()

def 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()

def 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])
    