MatrixUtil Namespace Reference

Classes
class	InputInfo
class	Matrix
class	Steps
class	WF

Functions
def	addForAll (steps, d)
def	changeRefRelease (steps, listOfPairs)
def	expandLsInterval (lumis)
def	genvalid (fragment, d, suffix='all', fi='', dataSet='')
def	Kby (N, s)
	Standard release validation samples ####. More...
def	Mby (N, s)
def	merge (dictlist, TELL=False)
def	remove (d, key, TELL=False)
def	selectedLS (list_runs=[], maxNum=-1, l_json=data_json2015)

Function Documentation

addForAll()

def MatrixUtil.addForAll	(		steps,
			d
	)

Definition at line 248 of file MatrixUtil.py.

def addForAll(steps,d):
    for s in steps:
        steps[s].update(d)
 
 

References update.

changeRefRelease()

def MatrixUtil.changeRefRelease	(		steps,
			listOfPairs
	)

Definition at line 236 of file MatrixUtil.py.

def changeRefRelease(steps,listOfPairs):
    for s in steps:
        if ('INPUT' in steps[s]):
            oldD=steps[s]['INPUT'].dataSet
            for (ref,newRef) in listOfPairs:
                if  ref in oldD:
                    steps[s]['INPUT'].dataSet=oldD.replace(ref,newRef)
        if '--pileup_input' in steps[s]:
            for (ref,newRef) in listOfPairs:
                if ref in steps[s]['--pileup_input']:
                    steps[s]['--pileup_input']=steps[s]['--pileup_input'].replace(ref,newRef)
        

References python.rootplot.root2matplotlib.replace().

Referenced by MatrixReader.MatrixReader.readMatrix().

expandLsInterval()

def MatrixUtil.expandLsInterval

(

lumis

)

Definition at line 48 of file MatrixUtil.py.

def expandLsInterval(lumis):
    return range(lumis[0],(lumis[1]+1))
 

References dcsonly_json_2012.findFileInPath(), and FastTimerService_cff.range.

genvalid()

def MatrixUtil.genvalid	(		fragment,
			d,
			suffix = 'all',
			fi = '',
			dataSet = ''
	)

Definition at line 253 of file MatrixUtil.py.

def genvalid(fragment,d,suffix='all',fi='',dataSet=''):
    import copy
    c=copy.copy(d)
    if suffix:
        c['-s']=c['-s'].replace('genvalid','genvalid_'+suffix)
    if fi:
        c['--filein']='lhe:%d'%(fi,)
    if dataSet:
        c['--filein']='das:%s'%(dataSet,)
    c['cfg']=fragment
    return c
 
 

References python.rootplot.root2matplotlib.replace().

Kby()

def MatrixUtil.Kby	(		N,
			s
	)

Standard release validation samples ####.

Definition at line 231 of file MatrixUtil.py.

def Kby(N,s):
    return {'--relval':'%s000,%s'%(N,s)}

Referenced by relval_steps.gen2018RD(), relval_steps.gen2021HiMix(), relval_steps.gen2021hiprod(), relval_steps.genS(), relval_steps.identitySim(), and relval_steps.lhegensim2018ml().

Mby()

def MatrixUtil.Mby	(		N,
			s
	)

Definition at line 233 of file MatrixUtil.py.

def Mby(N,s):
    return {'--relval':'%s000000,%s'%(N,s)}
 

Referenced by relval_steps.gen2021hiprod(), relval_steps.genS(), and relval_steps.identitySim().

merge()

def MatrixUtil.merge	(		dictlist,
			TELL = False
	)

Definition at line 201 of file MatrixUtil.py.

def merge(dictlist,TELL=False):
    import copy
    last=len(dictlist)-1
    if TELL: print(last,dictlist)
    if last==0:
        # ONLY ONE ITEM LEFT
        return copy.copy(dictlist[0])
    else:
        reducedlist=dictlist[0:max(0,last-1)]
        if TELL: print(reducedlist)
        # make a copy of the last item
        d=copy.copy(dictlist[last])
        # update with the last but one item
        d.update(dictlist[last-1])
        # and recursively do the rest
        reducedlist.append(d)
        return merge(reducedlist,TELL)
 

References SiStripPI.max, and print().

Referenced by CaloTowersCreationAlgo.assignHitHcal(), edm::EventProcessor.beginJob(), edm::SubProcess.keepOnlyConsumedUnscheduledModules(), tmtt::HTrphi.mergedCell(), DDI::LogicalPart.mergedSpecificsV(), DDExpandedView.mergedSpecificsV(), DAClusterizerInZ.vertices(), DAClusterizerInZ_vect.vertices(), and DAClusterizerInZT_vect.vertices().

remove()

def MatrixUtil.remove	(		d,
			key,
			TELL = False
	)

Definition at line 219 of file MatrixUtil.py.

def remove(d,key,TELL=False):
    import copy
    e = copy.deepcopy(d)
    if TELL: print("original dict, BEF: %s"%d)
    del e[key]
    if TELL: print("copy-removed dict, AFT: %s"%e)
    return e
 
 

References print().

Referenced by Mixins._Parameterizable.__delattr__(), DictTypes.SortedKeysDict.__delitem__(), BeautifulSoup.Tag.__delitem__(), tkal_create_file_lists.FileListCreator._fulfill_iov_eventcount(), EcalHexDisplay.analyze(), edmtest::DQMReferenceHistogramRootFileEventSetupAnalyzer.beginRun(), BTagDifferentialPlot.bookHisto(), BTagEntry.BTagEntry(), EtaPtBin.buildDescriptionString(), gen::BaseHadronizer.cleanLHE(), ValidationMatrix_v2.ReleaseComparison.compare(), edmStreamStallGrapher.createPDFImage(), AlignmentParameterBuilder.decodeParamSel(), edm.defaultModuleLabel(), edm::WorkerManager.deleteModuleIfExists(), evf::RecoEventOutputModuleForFU< Consumer >.endLuminosityBlock(), reco::ExpressionEvaluator.ExpressionEvaluator(), relval_steps.gen2021HiMix(), evf::EvFOutputModule.globalEndLuminosityBlock(), evf::EvFDaqDirector.grabNextJsonFileAndUnlock(), SpecificationBuilder_cfi.Specification.groupBy(), edm::shared_memory::WriteBuffer.growBuffer(), Pythia8Hadronizer.initializeForExternalPartons(), Pythia8Hadronizer.initializeForInternalPartons(), reco::details.loadTMVAWeights(), FFTJetPFPileupCleaner.produce(), evf::EvFDaqDirector.removeFile(), helpers.removeIfInSequence(), edm::UnscheduledCallProducer.removeWorker(), Phase1PixelMaps.retrieveCorners(), gen::Pythia6Service.setSLHAFromHeader(), edm::shared_memory::ControllerChannel.~ControllerChannel(), reco::ExpressionEvaluator.~ExpressionEvaluator(), InputFile.~InputFile(), and edm::shared_memory::WriteBuffer.~WriteBuffer().

selectedLS()

def MatrixUtil.selectedLS	(		list_runs = [],
			maxNum = -1,
			l_json = data_json2015
	)

Definition at line 64 of file MatrixUtil.py.

def selectedLS(list_runs=[],maxNum=-1,l_json=data_json2015):
    # print "maxNum is %s"%(maxNum)
    if not isinstance(list_runs[0], int):
        print("ERROR: list_runs must be a list of integers")
        return None
    local_dict = {}
    ls_count = 0
 
    for run in list_runs:
        if str(run) in l_json.keys():
            # print "run %s is there"%(run)
            runNumber = run
            # print "Doing lumi-section selection for run %s: "%(run)
            for LSsegment in l_json[str(run)] :
                # print LSsegment
                ls_count += (LSsegment[-1] - LSsegment[0] + 1)
                if (ls_count > maxNum) & (maxNum != -1):
                    break
                    # return local_dict
                if runNumber in local_dict.keys():
                    local_dict[runNumber].append(LSsegment)
                else: 
                    local_dict[runNumber] = [LSsegment]
                # print "total LS so far  %s    -   grow %s"%(ls_count,local_dict)
            #local_dict[runNumber] = [1,2,3]
        else:
            print("run %s is NOT present in json %s\n\n"%(run, l_json))
        # print "++    %s"%(local_dict)
 
    if ( len(local_dict) > 0 ) :
        return local_dict
    else :
        print("No luminosity section interval passed the json and your selection; returning None")
        return None
 
# print "\n\n\n THIS IS WHAT I RETURN: %s \n\n"%( selectedLS([251244,251251]) )
 
 
 
 
InputInfoNDefault=2000000    

References mps_setup.append, print(), and str.