python.LArNewCalib_MergeDB Namespace Reference

Functions
	DBConnectionFile (sqlitefile)
	mergeDBCfg (flags, InputKeys=[], InputSQLiteFiles=[])
	list_of_strings (arg)

Variables
	parser = argparse.ArgumentParser(formatter_class=argparse.ArgumentDefaultsHelpFormatter)
	dest
	default
	help
	type
	False
	action
	args = parser.parse_args()
list	InputSQLiteFiles = [ db for db in os.listdir(".") if db.endswith(".db") ]
	flags = initConfigFlags()
	RunNumbers
	Database
	Database2
	POOLFile
	DBConnection
	GlobalTag
	Files
	Ncoll
	IOVStart
	doAlign
	AtlasVersion
	DumpDetStore
	DumpCondStore
	cfg = MainServicesCfg(flags)
	WriteCatalog
	DBInstance
	withDetails
	True
	summariseProps
	printDefaults

Function Documentation

DBConnectionFile()

python.LArNewCalib_MergeDB.DBConnectionFile

(

sqlitefile

)

Definition at line 8 of file LArNewCalib_MergeDB.py.

def DBConnectionFile(sqlitefile):
   return "sqlite://;schema="+sqlitefile+";dbname=CONDBR2"
 

list_of_strings()

python.LArNewCalib_MergeDB.list_of_strings

(

arg

)

Definition at line 199 of file LArNewCalib_MergeDB.py.

    def list_of_strings(arg):
       return arg.split(',')
 

mergeDBCfg()

python.LArNewCalib_MergeDB.mergeDBCfg	(		flags,
			InputKeys = [],
			InputSQLiteFiles = [] )

Definition at line 11 of file LArNewCalib_MergeDB.py.

def mergeDBCfg(flags, InputKeys=[], InputSQLiteFiles=[]):
    result=ComponentAccumulator()
 
    print("mergeDBCfg",len(InputSQLiteFiles)," SQLite files: ",InputSQLiteFiles)
    print(len(InputKeys)," InputKeys: ",InputKeys)
 
 
    if not flags.LArCalib.isSC: GroupingType = "ExtendedSubDetector"
    else:     GroupingType = "SuperCells"
 
    if ( flags.LArCalib.Output.POOLFile ):
        if os.path.exists(flags.LArCalib.Output.POOLFile): 
            os.remove(flags.LArCalib.Output.POOLFile) 
 
    for key in InputKeys:
 
      print("Working for: ",key)
      KeyOutput = key
      FlagInput = key
 
      if 'Pedestal' == key or 'PhysWave' == key or 'MphysOverMcal' == key or 'Ramp' == key or 'Params' in key:
         KeyInput="LAr"+key
      if 'Pedestal' == key or 'PhysWave' == key or 'CaliWave' or 'MphysOverMcal' == key or 'Ramp' == key or 'Params' in key:
         KeyInput="LAr"+key
         KeyOutput="LAr"+key
 
      if 'AutoCorr' in key:
         KeyInput='LArAutoCorr'
 
      ofcphyskey=None
      if "OFC" in key:
         KeyInput = "LArOFC"
         if "Cali" in key:
            FlagInput = "OFCCali"
 
         if "Phys" in key:
            ofcphyskeytmp = key.split("OFCPhys")[1]
            if 'Mu' in ofcphyskeytmp:
               ofcphyskey=ofcphyskeytmp.replace("Mu","")
            else:   
               ofcphyskey=ofcphyskeytmp
            FlagInput = "OFCPhys"
 
      shapekey=None
      if "Shape" in key:
         shapekey = key.split("Shape")[1]
         FlagInput = "Shape"
         KeyInput = "LArShape"
 
 
      #if FlagInput in flags._flagdict.keys():       
      if   [i for i in flags._flagdict.keys() if FlagInput in i]:
         try: 
            Folder  = flags._get('LArCalib.'+FlagInput+'.Folder')  
         except Exception as e:
            print(e)
            print(flags._flagdict)
            sys.exit(-1)
      else:
         print('No folder in flags for '+FlagInput)
         print(flags._flagdict.keys())
         sys.exit(-2)
 
      if shapekey is not None:
         if Folder.endswith("/"):
            Folder+=shapekey
         else:
            Folder+="/"+shapekey
 
      if ofcphyskey is not None and ofcphyskey != "":
         print("Folder: ",Folder," ofcphyskey: ",ofcphyskey)
         if "4samples" in Folder:
            Folder = Folder.replace("4samples", ofcphyskey)
         elif Folder.endswith("/"):
            Folder+=ofcphyskey
         else:
            Folder+="/"+ofcphyskey
 
      if "OFCPhys" in FlagInput:
         print("Folder: ",Folder)
         # Get the available tags
         from PyCool import cool
         dbSvc=cool.DatabaseSvcFactory.databaseService()
         db_string=DBConnectionFile(InputSQLiteFiles[0])
         try:
            db=dbSvc.openDatabase(db_string)
         except Exception as e:
            print ('Problem opening database',e)
            print(db_string)
            sys.exit(-3)
         cool_folder=db.getFolder(Folder)
         tags = [ x for x in cool_folder.listTags() ]
         if len(tags) == 1:
            TagSpec = str(tags[0])
         else:
            if flags.LArCalib.OFC.Ncoll > 0 or 'Mu' in key:
               TagSpec = [ str(tag) for tag in tags if "-mu-" in str(tag)][0]
            else:
               TagSpec = [ str(tag) for tag in tags if "-mu-" not in str(tag)][0]
      else: 
         from LArCalibProcessing.utils import FolderTagResolver as FolderTagResover
         FolderTagResover._globalTag=flags.IOVDb.GlobalTag
         #rs=FolderTagResover(flags.LArCalib.Input.Database2)
         # until not all folders in COOL:
         rs=FolderTagResover(DBConnectionFile(InputSQLiteFiles[0]))
         FolderTag = rs.getFolderTagSuffix(Folder)
         del rs
 
         from LArCalibProcessing.LArCalibConfigFlags import LArCalibFolderTag
         TagSpec = LArCalibFolderTag(Folder,FolderTag)
 
 
      if 'Wave' in KeyInput:
         OutputObjectSpec = KeyInput+"Container#"+KeyOutput+"#"+Folder
      else:   
         OutputObjectSpec = KeyInput+"Complete#"+KeyOutput+"#"+Folder
      OutputObjectSpecTag = TagSpec
 
      print("**",KeyInput,FlagInput,"folder **",Folder)
      print("** TagSpec: ",TagSpec)
      print("** keyOutput: ",KeyOutput)
 
 
      inkeys=[]
      inobjs=[]
 
      for sqf in InputSQLiteFiles:
         thiskey = KeyInput+str(InputSQLiteFiles.index(sqf))
 
         if 'PhysAutoCorr' in key: thiskey='Phys'+thiskey
 
         if 'OFC' in key and 'Mu' in key:
            thiskey+="Mu"
         if 'OFC' in key and 'Cali' in key:
            thiskey+="Cali"   
 
         inkeys.append(thiskey)
         if 'Wave' in KeyInput: 
            inobjs.append(KeyInput+"Container#"+thiskey)
         else:   
            inobjs.append(KeyInput+"Complete#"+thiskey)
 
         if 'Wave' in KeyInput or 'Params' in KeyInput:
            result.merge(addFolders(flags,Folder,tag=TagSpec,detDb=sqf,modifiers="<key>"+thiskey+"</key>"))
         else:   
            result.merge(addFolders(flags,Folder,tag=TagSpec,detDb=sqf,modifiers="<key>"+thiskey+"</key>", className=KeyInput+"Complete"))
         pass   
 
      pass
 
      if 'Wave' in KeyInput:
         result.addCondAlgo(CompFactory.getComp('ForceLoadCondObj')(KeyOutput,ObjectList=inobjs))
         result.addCondAlgo(CompFactory.getComp('LArConditionsMergerAlg<LArDAC2uAComplete,'+KeyInput+'Container>')(key+"Merger",
                                              GroupingType = GroupingType, WriteKey = KeyOutput, DetStoreReadKeys = inkeys))    
      elif 'Params' in KeyInput:   
         result.addCondAlgo(CompFactory.getComp('ForceLoadCondObj')(KeyOutput,ObjectList=inobjs))
         result.addCondAlgo(CompFactory.getComp('LArConditionsMergerAlg<LArDAC2uAComplete,'+KeyInput+'Complete>')(key+"Merger",
                                              GroupingType = GroupingType, WriteKey = KeyOutput, DetStoreReadKeys = inkeys))    
      else:
         result.addCondAlgo(CompFactory.getComp('LArConditionsMergerAlg<'+KeyInput+'Complete, LArPhysWaveContainer>')(key+"Merger",
                                              GroupingType = GroupingType, WriteKey = KeyOutput, ReadKeys = inkeys))    
 
      if ( flags.LArCalib.Output.POOLFile ):
 
         from RegistrationServices.OutputConditionsAlgConfig import OutputConditionsAlgCfg
         result.merge(OutputConditionsAlgCfg(flags,name="OutputConditionsAlg"+KeyInput, outputFile=flags.LArCalib.Output.POOLFile,
                                                       ObjectList=[OutputObjectSpec], IOVTagList=[OutputObjectSpecTag],
                                                       Run1 = flags.LArCalib.IOVStart, Run2= flags.LArCalib.IOVEnd, WriteIOV=True))
    pass
 
    result.addService(CompFactory.IOVRegistrationSvc(RecreateFolders = False))
 
    #MC Event selector since we have no input data file
    from McEventSelector.McEventSelectorConfig import McEventSelectorCfg
    result.merge(McEventSelectorCfg(flags,
                                    RunNumber         = flags.LArCalib.Input.RunNumbers[0],
                                    EventsPerRun      = 1,
                                    FirstEvent        = 1,
                                    InitialTimeStamp  = 0,
                                    TimeStampInterval = 1))
 
    result.printConfig(withDetails=True, printDefaults=True)
    return result 
 
 

Variable Documentation

action

python.LArNewCalib_MergeDB.action

Definition at line 211 of file LArNewCalib_MergeDB.py.

args

python.LArNewCalib_MergeDB.args = parser.parse_args()

Definition at line 214 of file LArNewCalib_MergeDB.py.

AtlasVersion

python.LArNewCalib_MergeDB.AtlasVersion

Definition at line 255 of file LArNewCalib_MergeDB.py.

cfg

python.LArNewCalib_MergeDB.cfg = MainServicesCfg(flags)

Definition at line 264 of file LArNewCalib_MergeDB.py.

Database

python.LArNewCalib_MergeDB.Database

Definition at line 236 of file LArNewCalib_MergeDB.py.

Database2

python.LArNewCalib_MergeDB.Database2

Definition at line 237 of file LArNewCalib_MergeDB.py.

DBConnection

python.LArNewCalib_MergeDB.DBConnection

Definition at line 241 of file LArNewCalib_MergeDB.py.

DBInstance

python.LArNewCalib_MergeDB.DBInstance

Definition at line 276 of file LArNewCalib_MergeDB.py.

default

python.LArNewCalib_MergeDB.default

Definition at line 204 of file LArNewCalib_MergeDB.py.

dest

python.LArNewCalib_MergeDB.dest

Definition at line 204 of file LArNewCalib_MergeDB.py.

doAlign

python.LArNewCalib_MergeDB.doAlign

Definition at line 251 of file LArNewCalib_MergeDB.py.

DumpCondStore

python.LArNewCalib_MergeDB.DumpCondStore

Definition at line 258 of file LArNewCalib_MergeDB.py.

DumpDetStore

python.LArNewCalib_MergeDB.DumpDetStore

Definition at line 257 of file LArNewCalib_MergeDB.py.

False

python.LArNewCalib_MergeDB.False

Definition at line 211 of file LArNewCalib_MergeDB.py.

Files

python.LArNewCalib_MergeDB.Files

Definition at line 246 of file LArNewCalib_MergeDB.py.

flags

python.LArNewCalib_MergeDB.flags = initConfigFlags()

Definition at line 231 of file LArNewCalib_MergeDB.py.

GlobalTag

python.LArNewCalib_MergeDB.GlobalTag

Definition at line 244 of file LArNewCalib_MergeDB.py.

help

python.LArNewCalib_MergeDB.help

Definition at line 204 of file LArNewCalib_MergeDB.py.

InputSQLiteFiles

python.LArNewCalib_MergeDB.InputSQLiteFiles = [ db for db in os.listdir(".") if db.endswith(".db") ]

Definition at line 220 of file LArNewCalib_MergeDB.py.

IOVStart

python.LArNewCalib_MergeDB.IOVStart

Definition at line 249 of file LArNewCalib_MergeDB.py.

Ncoll

python.LArNewCalib_MergeDB.Ncoll

Definition at line 248 of file LArNewCalib_MergeDB.py.

parser

python.LArNewCalib_MergeDB.parser = argparse.ArgumentParser(formatter_class=argparse.ArgumentDefaultsHelpFormatter)

Definition at line 203 of file LArNewCalib_MergeDB.py.

POOLFile

python.LArNewCalib_MergeDB.POOLFile

Definition at line 239 of file LArNewCalib_MergeDB.py.

printDefaults

python.LArNewCalib_MergeDB.printDefaults

Definition at line 278 of file LArNewCalib_MergeDB.py.

RunNumbers

python.LArNewCalib_MergeDB.RunNumbers

Definition at line 235 of file LArNewCalib_MergeDB.py.

summariseProps

python.LArNewCalib_MergeDB.summariseProps

Definition at line 278 of file LArNewCalib_MergeDB.py.

True

python.LArNewCalib_MergeDB.True

Definition at line 278 of file LArNewCalib_MergeDB.py.

type

python.LArNewCalib_MergeDB.type

Definition at line 204 of file LArNewCalib_MergeDB.py.

withDetails

python.LArNewCalib_MergeDB.withDetails

Definition at line 278 of file LArNewCalib_MergeDB.py.

WriteCatalog

python.LArNewCalib_MergeDB.WriteCatalog

Definition at line 275 of file LArNewCalib_MergeDB.py.