parallelization Namespace Reference

Functions
def	adjust_pset (cmsrunfilename, savefilename, par_list)
def	cleanupandexit (filelist)
def	uint (string)

Function Documentation

def parallelization.adjust_pset	(		cmsrunfilename,
			savefilename,
			par_list
	)

Takes the cmsRun filem, removes all occurences of runMode, jobs,
   maxJobs and integrationList parameters in the process.generator
   part.
   The the parameters in par_list are set instead and saved.

Definition at line 59 of file parallelization.py.

Referenced by cleanupandexit().

def adjust_pset(cmsrunfilename, savefilename, par_list):
    """Takes the cmsRun filem, removes all occurences of runMode, jobs,
       maxJobs and integrationList parameters in the process.generator
       part.
       The the parameters in par_list are set instead and saved.
    """ 

    with open(cmsrunfilename, 'r') as readfile:
        parsestring = readfile.read()

        # get first opening bracket after process.generator
        begin_gen_step = parsestring.find('(', parsestring.find('process.generator'))

        # find matching bracket
        end_gen_step = begin_gen_step
        bracket_counter = 1
        for position in range(begin_gen_step+1, len(parsestring)):
            if parsestring[position] == '(':
                bracket_counter += 1
            if parsestring[position] == ')':
                bracket_counter -= 1
            if not bracket_counter:
                end_gen_step = position
                break

        # get string between brackets
        gen_string = parsestring[begin_gen_step+1:end_gen_step]

        # remove all parameters that would interfere
        gen_string = re.sub(r',\s*runModeList\s*=\s*cms.untracked.string\((.*?)\)', '', gen_string)
        gen_string = re.sub(r',\s*jobs\s*=\s*cms.untracked.int32\((.*?)\)', '', gen_string)
        gen_string = re.sub(r',\s*integrationList\s*=\s*cms.untracked.string\((.*?)\)', '', gen_string)
        gen_string = re.sub(r',\s*maxJobs\s*=\s*cms.untracked.uint32\((.*?)\)', '', gen_string)
        gen_string = re.sub(r',\s*seed\s*=\s*cms.untracked.int32\((.*?)\)', '', gen_string)


    # write the savefile with all parameters given in par_list
    with open(savefilename,'w') as savefile:
        savefile.write(parsestring[:begin_gen_step+1])
        savefile.write(gen_string)
        for item in par_list:
            savefile.write(',\n')
            savefile.write(item)
        savefile.write(parsestring[end_gen_step:])

def parallelization.cleanupandexit

(

filelist

)

Delete the files in filelist and exit

Definition at line 106 of file parallelization.py.

References adjust_pset(), and harvestTrackValidationPlots.str.

def cleanupandexit(filelist):
    """Delete the files in filelist and exit"""
    for filename in filelist:
        os.remove(filename)
    sys.exit(0)

def parallelization.uint

(

string

)

Unsigned int type

Definition at line 49 of file parallelization.py.

References createfilelist.int.

Referenced by SiStripMonitorDigi.AddApvShotsToSubDet(), L1Scalers.analyze(), SiStripMonitorHLT.analyze(), SiStripMonitorDigi.analyze(), MonitorTrackResidualsBase< pixel_or_strip >.analyze(), SiStripMonitorCluster.analyze(), SiPixelHitEfficiencySource.analyze(), SiPixelTrackResidualSource.analyze(), TkConvValidator.analyze(), MuIsoValidation.analyze(), L1Validator.analyze(), TrackingMonitor.analyze(), ZToMuMuGammaAnalyzer.analyze(), PhotonAnalyzer.analyze(), PhotonOfflineClient.book2DHistoVector(), PhotonAnalyzer.book2DHistoVector(), PhotonOfflineClient.book3DHistoVector(), PhotonAnalyzer.book3DHistoVector(), L1Scalers.bookHistograms(), TrackingMonitor.bookHistograms(), PhotonAnalyzer.bookHistogramsEfficiency(), TrackerOfflineValidation.bookSummaryHists(), EffectiveAreas.checkConsistency(), PFRecoTauDiscriminationByNProngs.discriminate(), CSCOfflineMonitor.doEfficiencies(), HLTMuonCertSummary.dqmEndJob(), EcalDAQTowerStatusXMLTranslator.dumpXML(), EcalDCSTowerStatusXMLTranslator.dumpXML(), L1TStage2InputPatternWriter.endJob(), GlobalHitsProdHistStripper.endRun(), VariableNTupler.fill(), StringBasedNTupler.fill(), AdHocNTupler.fill(), SiStripMonitorDigi.FillApvShotsMap(), CTPPSPixelLocalTrackProducer.fillDescriptions(), L1Validator.FindBest(), EffectiveAreas.getEffectiveArea(), ZElectronsSelector.getEffectiveArea(), TrackerOfflineValidation.getHistStructFromMap(), PixelInactiveAreaFinder.getPhiSpanBarrel(), SiStripTrackerMapCreator.paintTkMapFromAlarm(), PhotonMVAEstimatorRun2Spring16NonTrig.PhotonMVAEstimatorRun2Spring16NonTrig(), EcalDCSTowerStatusXMLTranslator.plot(), EcalDAQTowerStatusXMLTranslator.plot(), TrackerOfflineValidation.prepareSummaryHists(), EffectiveAreas.printEffectiveAreas(), ZElectronsSelector.printEffectiveAreas(), HiEvtPlaneFlatProducer.produce(), EvtPlaneProducer.produce(), L1TCaloParamsOnlineProd.readCaloLayer2OnlineSettings(), CompleteNTupler.registerleaves(), VariableNTupler.registerleaves(), AdHocNTupler.registerleaves(), StringBasedNTupler.registerleaves(), MuonTestSummary.ResidualCheck(), PhotonOfflineClient.retrieveHisto(), RPixPlaneCombinatoryTracking.RPixPlaneCombinatoryTracking(), PhotonOfflineClient.runClient(), StringCutEventSelector< Object, any >.select(), StringCutsEventSelector< Object, existenceMatter >.select(), TrackingMonitor.setMaxMinBin(), TrackingMonitor.setNclus(), StringBasedNTupler.StringBasedNTupler(), StringBranchHelper< Object, Collection >.StringBranchHelper(), TkConvValidator.TkConvValidator(), l1t::stage1.unpack_em(), l1t::stage1.unpack_region(), RctRawToDigi.unpackCTP7(), and VariableNTupler.VariableNTupler().

def uint(string):
    """Unsigned int type"""
    value = int(string)
    if value < 0:
        msg = '{0} is negative'.format(string)
        raise argparse.ArgumentTypeError(msg)
    return value