heppy_batch Namespace Reference

Classes
class	MyBatchManager

Functions
def	batchScriptCERN (jobDir, remoteDir='')
def	batchScriptIC (jobDir)
def	batchScriptLocal (remoteDir, index)
def	batchScriptPADOVA (index, jobDir='./')
def	batchScriptPISA (index, remoteDir='')
def	batchScriptPSI (index, jobDir, remoteDir='')

Variables
	args
	batchManager
	cfgFileName
	cfo
	components
	config
	handle
	heppyOptions_
	key
	listOfNames
	listOfValues
	options
	usage
	val
	waitingTime

Function Documentation

batchScriptCERN()

def heppy_batch.batchScriptCERN	(		jobDir,
			remoteDir = ''
	)

prepare the LSF version of the batch script, to run on LSF

Definition at line 78 of file heppy_batch.py.

References print(), python.rootplot.root2matplotlib.replace(), and nano_mu_digi_cff.strip.

Referenced by heppy_batch.MyBatchManager.PrepareJobUser().

def batchScriptCERN( jobDir, remoteDir=''):
    '''prepare the LSF version of the batch script, to run on LSF'''

    dirCopy = """echo 'sending the logs back'  # will send also root files if copy failed
rm Loop/cmsswPreProcessing.root
cp -r Loop/* $LS_SUBCWD
if [ $? -ne 0 ]; then
   echo 'ERROR: problem copying job directory back'
else
   echo 'job directory copy succeeded'
fi"""

    if remoteDir=='':
        cpCmd=dirCopy
    elif  remoteDir.startswith("root://eoscms.cern.ch//eos/cms/store/"):
        cpCmd="""echo 'sending root files to remote dir'
export LD_LIBRARY_PATH=/usr/lib64:$LD_LIBRARY_PATH # 
for f in Loop/*/tree*.root
do
   rm Loop/cmsswPreProcessing.root
   ff=`echo $f | cut -d/ -f2`
   ff="${{ff}}_`basename $f | cut -d . -f 1`"
   echo $f
   echo $ff
   export VO_CMS_SW_DIR=/cvmfs/cms.cern.ch
   source $VO_CMS_SW_DIR/cmsset_default.sh
   for try in `seq 1 3`; do
      echo "Stageout try $try"
      echo "/afs/cern.ch/project/eos/installation/pro/bin/eos.select mkdir {srm}"
      /afs/cern.ch/project/eos/installation/pro/bin/eos.select mkdir {srm}
      echo "/afs/cern.ch/project/eos/installation/pro/bin/eos.select cp `pwd`/$f {srm}/${{ff}}_{idx}.root"
      /afs/cern.ch/project/eos/installation/pro/bin/eos.select cp `pwd`/$f {srm}/${{ff}}_{idx}.root
      if [ $? -ne 0 ]; then
         echo "ERROR: remote copy failed for file $ff"
         continue
      fi
      echo "remote copy succeeded"
      remsize=$(/afs/cern.ch/project/eos/installation/pro/bin/eos.select find --size {srm}/${{ff}}_{idx}.root | cut -d= -f3) 
      locsize=$(cat `pwd`/$f | wc -c)
      ok=$(($remsize==$locsize))
      if [ $ok -ne 1 ]; then
         echo "Problem with copy (file sizes don't match), will retry in 30s"
         sleep 30
         continue
      fi
      echo "everything ok"
      rm $f
      echo root://eoscms.cern.ch/{srm}/${{ff}}_{idx}.root > $f.url
      break
   done
done
cp -r Loop/* $LS_SUBCWD
if [ $? -ne 0 ]; then
   echo 'ERROR: problem copying job directory back'
else
   echo 'job directory copy succeeded'
fi
""".format(
           idx = jobDir[jobDir.find("_Chunk")+6:].strip("/") if '_Chunk' in jobDir else 'all',
           srm = (""+remoteDir+jobDir[ jobDir.rfind("/") : (jobDir.find("_Chunk") if '_Chunk' in jobDir else len(jobDir)) ]).replace("root://eoscms.cern.ch/","")
           )
    else:
        print("chosen location not supported yet: ", remoteDir)
        print('path must start with /store/')
        sys.exit(1)

    script = """#!/bin/bash
#BSUB -q 8nm
echo 'environment:'
echo
env | sort
# ulimit -v 3000000 # NO
echo 'copying job dir to worker'
cd $CMSSW_BASE/src
eval `scramv1 ru -sh`
# cd $LS_SUBCWD
# eval `scramv1 ru -sh`
cd -
cp -rf $LS_SUBCWD .
ls
cd `find . -type d | grep /`
echo 'running'
python $CMSSW_BASE/src/PhysicsTools/HeppyCore/python/framework/looper.py pycfg.py config.pck --options=options.json
echo
{copy}
""".format(copy=cpCmd)

    return script

batchScriptIC()

def heppy_batch.batchScriptIC

(

jobDir

)

prepare a IC version of the batch script

Definition at line 264 of file heppy_batch.py.

Referenced by heppy_batch.MyBatchManager.PrepareJobUser().

def batchScriptIC(jobDir):
    '''prepare a IC version of the batch script'''


    cmssw_release = os.environ['CMSSW_BASE']
    script = """#!/bin/bash
export X509_USER_PROXY=/home/hep/$USER/myproxy
source /vols/cms/grid/setup.sh
cd {jobdir}
cd {cmssw}/src
eval `scramv1 ru -sh`
cd -
echo 'running'
python {cmssw}/src/PhysicsTools/HeppyCore/python/framework/looper.py pycfg.py config.pck --options=options.json
echo
echo 'sending the job directory back'
mv Loop/* ./ && rm -r Loop
""".format(jobdir = jobDir,cmssw = cmssw_release)
    return script

batchScriptLocal()

def heppy_batch.batchScriptLocal	(		remoteDir,
			index
	)

prepare a local version of the batch script, to run using nohup

Definition at line 284 of file heppy_batch.py.

Referenced by heppy_batch.MyBatchManager.PrepareJobUser().

def batchScriptLocal(  remoteDir, index ):
    '''prepare a local version of the batch script, to run using nohup'''

    script = """#!/bin/bash
echo 'running'
python $CMSSW_BASE/src/PhysicsTools/HeppyCore/python/framework/looper.py pycfg.py config.pck --options=options.json
echo
echo 'sending the job directory back'
mv Loop/* ./
""" 
    return script

batchScriptPADOVA()

def heppy_batch.batchScriptPADOVA	(		index,
			jobDir = './'
	)

prepare the LSF version of the batch script, to run on LSF

Definition at line 17 of file heppy_batch.py.

Referenced by heppy_batch.MyBatchManager.PrepareJobUser().

def batchScriptPADOVA( index, jobDir='./'):
    '''prepare the LSF version of the batch script, to run on LSF'''
    script = """#!/bin/bash
#BSUB -q local
#BSUB -J test
#BSUB -o test.log
cd {jdir}
echo 'PWD:'
pwd
export VO_CMS_SW_DIR=/cvmfs/cms.cern.ch
source $VO_CMS_SW_DIR/cmsset_default.sh
echo 'environment:'
echo
env > local.env
env
# ulimit -v 3000000 # NO
echo 'copying job dir to worker'
eval `scram runtime -sh`
ls
echo 'running'
python $CMSSW_BASE/src/PhysicsTools/HeppyCore/python/framework/looper.py pycfg.py config.pck --options=options.json >& local.output
exit $? 
#echo
#echo 'sending the job directory back'
#echo cp -r Loop/* $LS_SUBCWD 
""".format(jdir=jobDir)

    return script

batchScriptPISA()

def heppy_batch.batchScriptPISA	(		index,
			remoteDir = ''
	)

prepare the LSF version of the batch script, to run on LSF

Definition at line 46 of file heppy_batch.py.

Referenced by heppy_batch.MyBatchManager.PrepareJobUser().

def batchScriptPISA( index, remoteDir=''):
    '''prepare the LSF version of the batch script, to run on LSF'''
    script = """#!/bin/bash
#BSUB -q cms
echo 'PWD:'
pwd
export VO_CMS_SW_DIR=/cvmfs/cms.cern.ch
source $VO_CMS_SW_DIR/cmsset_default.sh
echo 'environment:'
echo
env > local.env
env
# ulimit -v 3000000 # NO
echo 'copying job dir to worker'
###cd $CMSSW_BASE/src
eval `scramv1 runtime -sh`
#eval `scramv1 ru -sh`
# cd $LS_SUBCWD
# eval `scramv1 ru -sh`
##cd -
##cp -rf $LS_SUBCWD .
ls
echo `find . -type d | grep /`
echo 'running'
python $CMSSW_BASE/src/PhysicsTools/HeppyCore/python/framework/looper.py pycfg.py config.pck --options=options.json >& local.output
exit $? 
#echo
#echo 'sending the job directory back'
#echo cp -r Loop/* $LS_SUBCWD 
"""
    return script

batchScriptPSI()

def heppy_batch.batchScriptPSI	(		index,
			jobDir,
			remoteDir = ''
	)

prepare the SGE version of the batch script, to run on the PSI tier3 batch system

Definition at line 168 of file heppy_batch.py.

References print().

def batchScriptPSI( index, jobDir, remoteDir=''):
    '''prepare the SGE version of the batch script, to run on the PSI tier3 batch system'''

    cmssw_release = os.environ['CMSSW_BASE']
    VO_CMS_SW_DIR = "/swshare/cms"  # $VO_CMS_SW_DIR doesn't seem to work in the new SL6 t3wn

    if remoteDir=='':
        cpCmd="""echo 'sending the job directory back'
rm Loop/cmsswPreProcessing.root
cp -r Loop/* $SUBMISIONDIR"""
    elif remoteDir.startswith("/pnfs/psi.ch"):
        cpCmd="""echo 'sending root files to remote dir'
export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:/usr/lib64/dcap/ # Fabio's workaround to fix gfal-tools
for f in Loop/mt2*.root
do
   ff=`basename $f | cut -d . -f 1`
   #d=`echo $f | cut -d / -f 2`
   gfal-mkdir {srm}
   echo "gfal-copy file://`pwd`/Loop/$ff.root {srm}/${{ff}}_{idx}.root"
   gfal-copy file://`pwd`/Loop/$ff.root {srm}/${{ff}}_{idx}.root
   if [ $? -ne 0 ]; then
      echo "ERROR: remote copy failed for file $ff"
   else
      echo "remote copy succeeded"
      rm Loop/$ff.root
   fi
done
rm Loop/cmsswPreProcessing.root
cp -r Loop/* $SUBMISIONDIR""".format(idx=index, srm='srm://t3se01.psi.ch'+remoteDir+jobDir[jobDir.rfind("/"):jobDir.find("_Chunk")])
    else:
        print("remote directory not supported yet: ", remoteDir)
        print('path must start with "/pnfs/psi.ch"')
        sys.exit(1)


    script = """#!/bin/bash
shopt expand_aliases
##### MONITORING/DEBUG INFORMATION ###############################
DATE_START=`date +%s`
echo "Job started at " `date`
cat <<EOF
################################################################
## QUEUEING SYSTEM SETTINGS:
HOME=$HOME
USER=$USER
JOB_ID=$JOB_ID
JOB_NAME=$JOB_NAME
HOSTNAME=$HOSTNAME
TASK_ID=$TASK_ID
QUEUE=$QUEUE

EOF
echo "######## Environment Variables ##########"
env
echo "################################################################"
TOPWORKDIR=/scratch/`whoami`
JOBDIR=sgejob-$JOB_ID
WORKDIR=$TOPWORKDIR/$JOBDIR
SUBMISIONDIR={jdir}
if test -e "$WORKDIR"; then
   echo "ERROR: WORKDIR ($WORKDIR) already exists! Aborting..." >&2
   exit 1
fi
mkdir -p $WORKDIR
if test ! -d "$WORKDIR"; then
   echo "ERROR: Failed to create workdir ($WORKDIR)! Aborting..." >&2
   exit 1
fi

#source $VO_CMS_SW_DIR/cmsset_default.sh
source {vo}/cmsset_default.sh
export SCRAM_ARCH=slc6_amd64_gcc481
#cd $CMSSW_BASE/src
cd {cmssw}/src
shopt -s expand_aliases
cmsenv
cd $WORKDIR
cp -rf $SUBMISIONDIR .
ls
cd `find . -type d | grep /`
echo 'running'
python $CMSSW_BASE/src/PhysicsTools/HeppyCore/python/framework/looper.py pycfg.py config.pck --options=options.json
#python $CMSSW_BASE/src/CMGTools/RootTools/python/fwlite/looper.py config.pck
echo
{copy}
###########################################################################
DATE_END=`date +%s`
RUNTIME=$((DATE_END-DATE_START))
echo "################################################################"
echo "Job finished at " `date`
echo "Wallclock running time: $RUNTIME s"
exit 0
""".format(jdir=jobDir, vo=VO_CMS_SW_DIR,cmssw=cmssw_release, copy=cpCmd)

    return script

Variable Documentation

args

heppy_batch.args

Definition at line 346 of file heppy_batch.py.

batchManager

heppy_batch.batchManager

Definition at line 338 of file heppy_batch.py.

cfgFileName

heppy_batch.cfgFileName

Definition at line 357 of file heppy_batch.py.

cfo

heppy_batch.cfo

Definition at line 361 of file heppy_batch.py.

components

heppy_batch.components

Definition at line 365 of file heppy_batch.py.

config

heppy_batch.config

Definition at line 362 of file heppy_batch.py.

handle

heppy_batch.handle

Definition at line 359 of file heppy_batch.py.

heppyOptions_

heppy_batch.heppyOptions_

Definition at line 355 of file heppy_batch.py.

key

heppy_batch.key

Definition at line 351 of file heppy_batch.py.

listOfNames

heppy_batch.listOfNames

Definition at line 367 of file heppy_batch.py.

listOfValues

heppy_batch.listOfValues

Definition at line 366 of file heppy_batch.py.

options

heppy_batch.options

Definition at line 346 of file heppy_batch.py.

usage

heppy_batch.usage

Definition at line 339 of file heppy_batch.py.

val

heppy_batch.val

Definition at line 351 of file heppy_batch.py.

Referenced by edm::TrieNode< T >._sequentialSearch(), SiStripMiscalibrate::Entry.add(), SiStripPI::Entry.add(), FWRecoGeometryESProducer.addCaloGeometry(), ClusterSummary.addClusCharge(), ClusterSummary.addClusChargeByIndex(), ClusterSummary.addClusSize(), ClusterSummary.addClusSizeByIndex(), cms::DDNamespace.addConstant(), cms::DDNamespace.addConstantNS(), pat::helper::AddUserIntFromBool.addData(), pat::helper::AddUserInt.addData(), pat::helper::AddUserFloat.addData(), pat::helper::AddUserPtr.addData(), pat::helper::AddUserCand.addData(), TMTQ.addEntry(), TAPD.addEntry(), TPN.addEntry(), TMom.addEntry(), Entry.addFittedDisplacementToValue(), ClusterSummary.addNClus(), ClusterSummary.addNClusByIndex(), fit::RootMinuit< Function >.addParameter(), ALIUtils.addPii(), OpticalObject.addPii(), ParameterMgr.addRandomFlatParameter(), ParameterMgr.addRandomGaussParameter(), OMTFResult.addResult(), PixelRecoLineRZ.addTIP(), HLTPrescaleExample.analyze(), CTPPSProtonReconstructionEfficiencyEstimatorData.analyze(), cms::SiPixelCondObjForHLTBuilder.analyze(), cms::SiPixelCondObjOfflineBuilder.analyze(), BTVHLTOfflineSource.analyze(), EcalTPGParamBuilder.analyze(), JanAlignmentAlgorithm.analyze(), FSQ::HandlerTemplate< TInputCandidateType, TOutputCandidateType, filter >.analyze(), PackedCandidateTrackValidator.analyze(), TaggingVariablePlotter.analyzeTag(), ALIUtils.approxTo0(), OpticalObject.approxTo0(), BitArray< 9 >.assign(), DTTFBitArray< N >.assign(), cms::cudacompat.atomicCAS(), cms::cudacompat.atomicCAS_block(), atomicMaxF(), atomicMaxPair(), cms::DDNamespace.attr(), PrintGeomInfoAction.beginRun(), HistogramManager.book(), HGVHistoProducerAlgo.bookTracksterSTSHistos(), HGCalParametersFromDD.build(), HGCalTBParametersFromDD.build(), DTGeometryBuilderFromDDD.buildGeometry(), DTGeometryParsFromDD.buildGeometry(), XMLConfigReader.buildGP(), L1TDTTFClient.buildHighQualityPlot(), L1TDTTFClient.buildPhiEtaPlotO(), DTCompactMapWriter.buildSteering(), FWPFLegoRecHit.buildTower(), DTReadOutMapping.cacheMap(), emtf.calc_eta_GMT(), emtf.calc_phi_GMT_int(), emtf.calc_pt_GMT(), ticl::TracksterP4FromEnergySum.calcP4(), SiPixelGainCalibrationAnalysis.CalculateAveragePerColumn(), ESIntegrityTask.calculateDIFraction(), SiPixelIsAliveCalibration.calibrationEnd(), hitfit::Base_Constrainer.call_constraint_fcn(), Cell.check(), edm::service::MessageServicePSetValidation.check(), HGCDigitizer.checkPosition(), RBXAndHPDCleaner.clean(), SiPixelCalibConfiguration.columnPatternForEvent(), EcalSelectiveReadout.combineFlags(), reco::EcalClustersGraph.computeWindowVariables(), edmtest::ConcurrentIOVESSource.ConcurrentIOVESSource(), TtSemiLepKinFitProducer< LeptonCollection >.constraint(), TtSemiEvtSolutionMaker.constraint(), TtSemiLepKinFitProducer< LeptonCollection >.constraints(), TtSemiEvtSolutionMaker.constraints(), Measurement.constructFromOA(), CaloTowersCreationAlgo.convert(), HLTPrescaleProvider.convertL1PS(), HLTDQMMuonSelector.convertToEnum(), geant_units::operators.convertUnitsTo(), Cordic.Cordic(), MeasurementSensor2D.correctValueAndSigma(), MeasurementCOPS.correctValueAndSigma(), MeasurementDistancemeter.correctValueAndSigma(), MeasurementDistancemeter3dim.correctValueAndSigma(), MeasurementTiltmeter.correctValueAndSigma(), RPCFw.createGAS(), RPCFw.createIMON(), RPCFw.createSTATUS(), RPCFw.createT(), RPCFw.createVMON(), ConformalMappingFit.curvature(), Selector< pat::Electron >.cut(), vid::CutFlowResult.CutFlowResult(), ConfigurationDBHandler.cvt2String(), dd_exchange_value(), DDValue.DDValue(), DEutils< T >.de_equal(), DEutils< T >.de_equal_loc(), edm.decode(), edm.decode_deprecated(), FWGUIManager.delaySliderChanged(), trklet::KFin.digi(), trklet::DRin.digi(), trackerTFP::DataFormatKF.digi(), ConformalMappingFit.directionPhi(), TMatacq.doFit(), hitfit::Defaults_Textrep.doline(), TrackerMap.drawPalette(), Phase2TrackerDigitizerAlgorithm.drift(), HLTConfigData.dump(), FittedEntriesManager.dumpEntriesSubstraction(), L1DataEmulDigi.empty(), EcalMatacqAnalyzer.endJob(), edmtest::TestFindProduct.endProcessBlock(), edm::Entry.Entry(), jpt::Map.etaBin(), ValueMapVariable< ObjType, TIn, ValType >.eval(), TypedValueMapVariable< ObjType, TIn, StringFunctor, ValType >.eval(), magfieldparam::HarmBasis3DCyl.EvalBphi(), magfieldparam::HarmBasis3DCyl.EvalRZ(), fit::LikelihoodEvaluator< PDF, double >.evaluate(), hitfit::Defaults_Text.exists(), GeometryInterface.extract(), GeometryInterface.extractColumns(), sistrip::SpyUtilities.extractFrameInfo(), CastorDataFrame.fiberIdleOffset(), ZDCDataFrame.fiberIdleOffset(), HBHEDataFrame.fiberIdleOffset(), HFDataFrame.fiberIdleOffset(), HODataFrame.fiberIdleOffset(), HcalCalibDataFrame.fiberIdleOffset(), SiStripTkMaps.fill(), l1tpf_calo::GridData< PreCluster >.fill(), HcalObjRepresent.Fill(), QcdUeDQM.fill1D(), QcdLowPtDQM.fill1D(), SiStripBadComponentInfo.fillBadComponentMaps(), SiPixelPhase1Analyzer.FillBarrelBinsRemap(), TrackerRemapper.fillBarrelRemap(), Measurement.fillData(), edm::service::RandomNumberGeneratorService.fillDescriptions(), TrackerRemapper.fillEndcapRemap(), SiPixelPhase1Analyzer.FillForwardBinsRemap(), Entry.fillFromInputFileValue(), SmartSelectionMonitor.fillHisto(), Phase2TrackerValidateDigi.fillHistogram(), SiStripSummaryCreator.fillHistos(), LRHelpFunctions.fillLRBackgroundHist(), LRHelpFunctions.fillLRSignalHist(), MuonTrackValidatorBase.fillPlotNoFlow(), DiLepPlotHelp::PlotsVsKinematics.fillPlots(), DiLeptonHelp::PlotsVsKinematics.fillPlots(), TrackingNtuple.fillSeeds(), APDShape.fillShape(), FSQ::HandlerTemplate< TInputCandidateType, TOutputCandidateType, filter >.fillSingleObjectPlots(), TrackingQualityChecker.fillStatusHistogram(), SiStripQualityChecker.fillStatusHistogram(), TrackerRemapper.fillStripRemap(), DiLeptonHelp::PlotsVsDiLeptonRegion.fillTH1Plots(), FWHGTowerProxyBuilderBase.fillTowerForDetId(), FWHFTowerProxyBuilderBase.fillTowerForDetId(), TrackingCertificationInfo.fillTrackingCertificationMEs(), TrackingCertificationInfo.fillTrackingCertificationMEsAtLumi(), reco::EcalClustersGraph.fillVariables(), OMTFResult.finalise(), CellDB.find(), ParabolaFit.fixParC(), ALPAKA_ACCELERATOR_NAMESPACE::hcal::reconstruction::mahi.float_as_uint(), GeometryInterface.formatValue(), GlobalCoordsObtainer.from_two_comp(), FWLegoCandidate.FWLegoCandidate(), FWLegoEvePFCandidate.FWLegoEvePFCandidate(), l1tmhtemu.generatemagNormalisationLUT(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::GsfTrackCollection, unsigned short > >.get(), hitfit::Defaults_Text.get_bool(), hitfit::Defaults_Textrep.get_val(), edm::Entry.getBool(), ALIUtils.getBool(), DCCDataUnpacker.getCCUValue(), HGCalTBParametersFromDD.getDDDArray(), HGCalParametersFromDD.getDDDArray(), HGCalTBParametersFromDD.getDDDValue(), HGCalParametersFromDD.getDDDValue(), DDG4Builder.getDouble(), edm::Entry.getDouble(), edm::Entry.getESInputTag(), edm::Entry.getEventID(), edm::Entry.getEventRange(), edm::Entry.getFileInPath(), HGCalGeometryMode.getGeometryMode(), HGCalGeometryMode.getGeometryWaferMode(), GlobalOptionMgr.getGlobalOption(), GlobalOptionMgr.getGlobalOptionValue(), SiPixelGainCalibrationReadDQMFile.getHistograms(), edm::Entry.getInputTag(), DDG4Builder.getInt(), MuonGeometryNumbering.getInt(), edm::Entry.getInt32(), edm::Entry.getInt64(), TtHadEvtSolution.getLRJetCombObsVal(), TtSemiEvtSolution.getLRJetCombObsVal(), TtDilepEvtSolution.getLRSignalEvtObsVal(), TtHadEvtSolution.getLRSignalEvtObsVal(), TtSemiEvtSolution.getLRSignalEvtObsVal(), edm::Entry.getLuminosityBlockID(), edm::Entry.getLuminosityBlockRange(), TrackingUtility.getMEValue(), SiStripUtility.getMEValue(), popcon::EcalADCToGeVHandler.getNewObjects(), fit::RootMinuit< Function >.getParameter(), fit::RootMinuit< Function >.getParameterError(), ParameterMgr.getParameterValue(), Model.getParameterValue(), edm::Entry.getPSet(), SSDigitizerAlgorithm.getSignalScale(), ExtractStringFromDD< FilteredView >.getString(), ExtractStringFromDDD< FilteredView >.getString(), DDG4SensitiveConverter.getString(), edm::Entry.getString(), TrajSeedMatcher.getTrajStateFromPoint(), TrajSeedMatcher.getTrajStateFromVtx(), edm::Entry.getUInt32(), edm::Entry.getUInt64(), ParameterMgr.getVal(), MELaserPrim.getVal(), reco::ElectronSeed.getVal(), SiStripCondObjBuilderFromDb.getValue(), cond::Utilities.getValueIfExists(), edm::Entry.getVDouble(), edm::Entry.getVESInputTag(), edm::Entry.getVEventID(), edm::Entry.getVEventRange(), edm::Entry.getVInputTag(), edm::Entry.getVInt32(), edm::Entry.getVInt64(), edm::Entry.getVLuminosityBlockID(), edm::Entry.getVLuminosityBlockRange(), edm::Entry.getVPSet(), edm::Entry.getVString(), edm::Entry.getVUInt32(), edm::Entry.getVUInt64(), GenWeightsTableProducer.globalEndRunProduce(), FWMagField.guessField(), SiStripGainFromAsciiFile::ModuleGain.hard_reset(), hitfit::Objpair.has_constraint(), edm.hash_combine(), SiStripSpyMonitorModule.hasNegativePedSubtr(), ConformalMappingFit.impactParameter(), PDFWeightsHelper.Init(), MuonResidualsFitter.initialize_table(), L2TauNNProducerAlpaka.initializeGlobalCache(), L2TauNNProducer.initializeGlobalCache(), CTPPSRPAlignmentCorrectionsMethods.iovValueToString(), DEutils< T >.is_empty(), GsfEleEcalDrivenCut.isValidCutVal(), DTBtiChip.keepTrig(), DTBtiChip.keepTrigPatt(), L1GtPsbSetupTrivialProducer.L1GtPsbSetupTrivialProducer(), FWPFMaths.lineLineIntersect(), TrackerMap.load(), UnbinnedLikelihoodFit.logL(), SiStripApvShotCleaner.loop(), CmsShowCommon.loopPalettes(), main(), mtrReset(), ResidualRefitting.muonInfo(), MuonResidualsFitter_logPowerLawTails(), FWFileEntry.nextSelectedEvent(), edm::service::MessageServicePSetValidation.noneExcept(), nanoaod::flatTableHelper::MaybeMantissaReduce< T >.one(), nanoaod::flatTableHelper::MaybeMantissaReduce< float >.one(), PhoMVACut.operator()(), GsfEleMVACut.operator()(), GsfEleValueMapIsoRhoCut.operator()(), StringMap::MatchByString.operator()(), StringMap::MatchByNumber.operator()(), take_address.operator()(), ALPAKA_ACCELERATOR_NAMESPACE::hcal::reconstruction::mahi::Kernel_prep1d_sameNumberOfSamples.operator()(), cond::persistency::GetFromRow< std::array< char, n > >.operator()(), BitArray< N >::refToBit.operator=(), DTTFBitArray< N >::refToBit.operator=(), l1ct::ParticleID.operator=(), edm::AssociationMap< edm::OneToOne< std::vector< Trajectory >, reco::GsfTrackCollection, unsigned short > >.operator[](), HcalHTRData.packUnsuppressed(), hitfit::Pair_Table.Pair_Table(), TtSemiLepKinFitProducer< LeptonCollection >.param(), TtSemiEvtSolutionMaker.param(), cms::DDAlgoArguments.parentName(), lumi::NormDML.parseAfterglows(), pos::PixelCalibConfiguration.PixelCalibConfiguration(), DBoxMetadataHelper::DBMetaDataPlotDisplay.plotDiffWithMetadata(), TFParams.polfit(), FWFileEntry.previousSelectedEvent(), helper::ScannerBase.print(), edm::service::RandomNumberGeneratorService.print(), DBoxMetadataHelper::DBMetaDataTableDisplay.printDiffWithMetadata(), DBoxMetadataHelper::DBMetaDataTableDisplay.printMetaDatas(), SiStripDetVOffBuilder.printPar(), printTrackerMap(), MultiVertexFitter.printWeights(), DDLSpecPar.processElement(), JetChargeProducer.produce(), MFProducer.produce(), EcalCATIAGainRatiosESProducer.produce(), MultiClustersFromTrackstersProducer.produce(), MultShiftMETcorrInputProducer.produce(), MultShiftMETcorrDBInputProducer.produce(), SoftKillerProducer.produce(), L1RCTOmdsFedVectorProducer.produce(), ALPAKA_ACCELERATOR_NAMESPACE::EcalMultifitConditionsHostESProducer.produce(), L1FPGATrackProducer.produce(), cms::CkfTrackCandidateMakerBase.produceBase(), ecaldqm::MLClient.producePlots(), jpt::Map.ptBin(), cmsutils::bqueue< TrajectoryMeasurement >.push_back(), TShapeAnalysis.putalphaInit(), TShapeAnalysis.putalphaVal(), TShapeAnalysis.putbetaInit(), TShapeAnalysis.putbetaVal(), TShapeAnalysis.putchi2Init(), TShapeAnalysis.putchi2Val(), TShapeAnalysis.putetaInit(), TShapeAnalysis.putflagInit(), TShapeAnalysis.putflagVal(), TShapeAnalysis.putphiInit(), TShapeAnalysis.putwidthInit(), TShapeAnalysis.putwidthVal(), RunInfoRead.readData(), EcalFEtoDigi.readInput(), L1MuGMTHWFileReader.readNextEvent(), popcon::EcalPFRecHitThresholdsHandler.readTXT(), popcon::EcalIntercalibHandler.readTXT(), EcalFloatCondObjectContainerXMLTranslator.readXML(), popcon::EcalPFRecHitThresholdsHandler.readXML(), popcon::EcalIntercalibHandler.readXML(), cms::DDNamespace.realName(), HcalDigisValidation.reco(), DBoxMetadataHelper::RecordMetaDataInfo.RecordMetaDataInfo(), trklet::DRin.redigi(), TagName.regName(), FitWithRooFit.reinitializeParameters(), edm::service::IgProfService.replace(), edm::service::JeProfService.replace(), mkfit::ConfigJsonPatcher.replace(), edm::service::IgProfService.replaceU64(), edm::service::JeProfService.replaceU64(), cms::DDAlgoArguments.resolved_scalar_arg(), edm::service::RandomNumberGeneratorService.restoreFromCache(), StoredPileupJetIdentifier.RMS(), cms::rotation_utils.rotHash(), SiPixelCalibConfiguration.rowPatternForEvent(), cms::CSJetProducer.runAlgorithm(), DTOccupancyTestML.runOccupancyTest(), cond::impl.s_to_f(), cond::impl.s_to_i(), cond::impl.s_to_time(), cond::impl.s_to_ul(), cond::impl.s_to_ull(), SiStripApvSimulationParameters.sampleBarrel(), SiStripApvSimulationParameters.sampleEndcap(), deepmet_helper.scale_and_rm_outlier(), FakeBeamMonitor.scrollTH1(), BeamMonitor.scrollTH1(), cond::persistency.search(), theLHCInfoImpl.search(), pf2pat::IsolatedPFCandidateSelectorDefinition.select(), Selector< pat::Electron >.set(), pat::strbitset.set(), BitArray< 9 >.set(), DTTFBitArray< N >.set(), l1t::EMTFTrack.set_dxy(), l1t::EMTFTrack.set_eta(), l1t::EMTFHit.set_eta(), l1t::EMTFHit.set_eta_sim(), L1MuDTTFMasks.set_etsoc_chdis_st1(), L1MuDTTFMasks.set_etsoc_chdis_st2(), L1MuDTTFMasks.set_etsoc_chdis_st3(), L1MuDTTFMasks.set_inrec_chdis_csc(), L1MuDTTFMasks.set_inrec_chdis_st1(), L1MuDTTFMasks.set_inrec_chdis_st2(), L1MuDTTFMasks.set_inrec_chdis_st3(), L1MuDTTFMasks.set_inrec_chdis_st4(), L1MuDTTFParameters.set_inrec_qual_st1(), L1MuDTTFParameters.set_inrec_qual_st2(), L1MuDTTFParameters.set_inrec_qual_st3(), L1MuDTTFParameters.set_inrec_qual_st4(), l1t::EMTFTrack.set_phi_glob(), l1t::EMTFHit.set_phi_glob(), l1t::EMTFTrack.set_phi_loc(), l1t::EMTFHit.set_phi_loc(), l1t::EMTFHit.set_phi_sim(), l1t::EMTFTrack.set_pt(), l1t::EMTFTrack.set_pt_dxy(), l1t::EMTFTrack.set_pt_XML(), l1t::EMTFHit.set_rho_sim(), L1MuDTTFParameters.set_soc_csc_etacanc(), L1MuDTTFParameters.set_soc_nbx_del(), L1MuDTTFParameters.set_soc_openlut_extr(), L1MuDTTFParameters.set_soc_qcut_st1(), L1MuDTTFParameters.set_soc_qcut_st2(), L1MuDTTFParameters.set_soc_qcut_st4(), L1MuDTTFParameters.set_soc_qual_csc(), L1MuDTTFParameters.set_soc_run_21(), L1MuDTTFParameters.set_soc_stdis_n(), L1MuDTTFParameters.set_soc_stdis_wl(), L1MuDTTFParameters.set_soc_stdis_wr(), L1MuDTTFParameters.set_soc_stdis_zl(), L1MuDTTFParameters.set_soc_stdis_zr(), l1t::EMTFTrack.set_theta(), l1t::EMTFHit.set_theta(), l1t::EMTFHit.set_theta_sim(), l1t::EMTFHit.set_time(), cms.set_to_default(), l1t::EMTFHit.set_z_sim(), edm::ProcessBlockHelperBase.setAddedProcesses(), GlobalAlgBlk.setAlgoDecisionFinal(), GlobalAlgBlk.setAlgoDecisionInitial(), GlobalAlgBlk.setAlgoDecisionInterm(), SimBeamSpotObjects.setAlpha(), ALIRmDataFromFile.setAngle(), ALIRmDataFromFile.setAngleX(), ALIRmDataFromFile.setAngleY(), ALIRmDataFromFile.setAngleZ(), DeviationsFromFileSensor2D.setApply(), TotemVFATStatus.setBCProgressError(), BeamSpotObjects.setBeamWidthX(), BeamSpotObjects.setBeamWidthXError(), BeamSpotObjects.setBeamWidthY(), BeamSpotObjects.setBeamWidthYError(), SimBeamSpotObjects.setBetaStar(), BeamSpotObjects.setBetaStar(), Conv4HitsReco2.SetBField(), SLBin.setBin(), MEGeom.setBinGlobalHist(), PFPileUpAlgo.setCheckClosestZVertex(), l1t::GlobalBoard.setCICADAScore(), edm::RunProcessingStatus.setCleaningUpAfterException(), l1t::CaloCluster.setClusterFlag(), BSFitter.SetConvergence(), BeamSpotObjects.setCovariance(), edm::service::ResourceInformationService.setCpuAverageSpeed(), edm::service::ResourceInformationService.setCPUModels(), edm::service::ResourceInformationService.setCpuModelsFormatted(), EcalHitMaker.setCrackPadSurvivalProbability(), TotemVFATStatus.setCRCError(), edm::service::ResourceInformationService.setCudaDriverVersion(), edm::service::ResourceInformationService.setCudaRuntimeVersion(), DataModeScoutingRun3.setDataBlockInitialized(), DataModeFRDStriped.setDataBlockInitialized(), ALIUtils.setDebugVerbosity(), FWGUIManager.setDelayBetweenEvents(), reco::PFCandidateElectronExtra.setDeltaEta(), reco::PFCandidateEGammaExtra.setDeltaEta(), BeamSpotObjects.setdxdz(), BeamSpotObjects.setdydz(), PFPileUpAlgo.setDzCutForChargedFromPUVtxs(), reco::PFCandidateElectronExtra.setEarlyBrem(), reco::PFCandidateEGammaExtra.setEarlyBrem(), reco::PFBlockElementSuperCluster.setEcalIso(), pat::Electron.setEcalRegressionEnergy(), pat::Electron.setEcalRegressionScale(), pat::Electron.setEcalRegressionSmear(), pat::Electron.setEcalScale(), pat::Electron.setEcalSmear(), pat::Electron.setEcalTrackRegressionEnergy(), pat::Electron.setEcalTrackRegressionScale(), pat::Electron.setEcalTrackRegressionSmear(), TotemVFATStatus.setECProgressError(), SimBeamSpotObjects.setEmittance(), BeamSpotObjects.setEmittanceX(), BeamSpotObjects.setEmittanceY(), HGCalSiNoiseMap< HGCSiliconDetId >.setENCCommonNoiseSubScale(), reco::HFValueStruct.setEnCor(), edm::RunProcessingStatus.setEndingEventSetupSucceeded(), edm::LuminosityBlockProcessingStatus.setEventProcessingState(), GlobalExtBlk.setExternalDecision(), OpticalObject.setExtraEntryValue(), ElectronLimiter.SetFieldCheckFlag(), ALIUtils.setFirstTime(), TtEvent.setFitChi2(), TtEvent.setFitProb(), Conv4HitsReco2.SetFixedNumberOfIterations(), HGCalRadiationMap.setFluenceScaleFactor(), TotemVFATStatus.setFootprintError(), reco::PFBlockElementSuperCluster.setFromGsfElectron(), reco::PFBlockElementSuperCluster.setFromPFSuperCluster(), reco::PFBlockElementSuperCluster.setFromPhoton(), TtEvent.setGenMatchSumDR(), TtEvent.setGenMatchSumPt(), GlobalOptionMgr.setGlobalOption(), L1TDTTFClient.setGMTsummary(), edm::service::ResourceInformationService.setGPUModels(), L1GtTriggerMenuXmlParser.setGtAlgorithmImplementation(), l1t::TriggerMenuParser.setGtAlgorithmImplementation(), L1GtTriggerMenuXmlParser.setGtTriggerMenuAuthor(), l1t::TriggerMenuParser.setGtTriggerMenuAuthor(), L1GtTriggerMenuXmlParser.setGtTriggerMenuDate(), l1t::TriggerMenuParser.setGtTriggerMenuDate(), L1GtTriggerMenuXmlParser.setGtTriggerMenuDescription(), l1t::TriggerMenuParser.setGtTriggerMenuDescription(), L1GtTriggerMenuXmlParser.setGtTriggerMenuInterfaceAuthor(), l1t::TriggerMenuParser.setGtTriggerMenuInterfaceAuthor(), L1GtTriggerMenuXmlParser.setGtTriggerMenuInterfaceDate(), l1t::TriggerMenuParser.setGtTriggerMenuInterfaceDate(), L1GtTriggerMenuXmlParser.setGtTriggerMenuInterfaceDescription(), l1t::TriggerMenuParser.setGtTriggerMenuInterfaceDescription(), reco::PFCandidateElectronExtra.setHadEnergy(), reco::PFCandidateEGammaExtra.setHadEnergy(), reco::PFBlockElementSuperCluster.setHcalIso(), EcalSelectiveReadout.setHigher(), TtEvent.setHitFitChi2(), TtEvent.setHitFitMT(), TtEvent.setHitFitProb(), TtEvent.setHitFitSigMT(), reco::PFBlockElementSuperCluster.setHoE(), TotemVFATStatus.setIDMismatch(), BSFitter.SetInputBeamWidth(), L1MuGMTInputEvent.setIsoBit(), Entry.setLastAdditionToValueDisplacementByFitting(), BeamSpotOnlineObjects.setLastAnalyzedFill(), BeamSpotOnlineObjects.setLastAnalyzedLumi(), BeamSpotOnlineObjects.setLastAnalyzedRun(), reco::PFCandidateElectronExtra.setLateBrem(), reco::PFCandidateEGammaExtra.setLateBrem(), EcalSelectiveReadout.setLower(), edm::LuminosityBlockProcessingStatus.setLumiPrincipal(), ALIUtils.setMaximumDeviationDerivative(), Conv4HitsReco2.SetMaxNumberOfIterations(), SimBeamSpotObjects.setMeanX(), SimBeamSpotObjects.setMeanY(), SimBeamSpotObjects.setMeanZ(), PhotonEnergyCalibrator.setMinEt(), ElectronEnergyCalibrator.setMinEt(), TTUTrackingAlg.setMinTrkLength(), L1MuGMTInputEvent.setMipBit(), TotemVFATStatus.setMissing(), SimWatcher.setMT(), reco::PFCandidateElectronExtra.setMVA(), reco::PFCandidateEGammaExtra.setMVA(), TtEvent.setMvaDiscriminators(), edm::EventProcessor.setNeedToCallNext(), reco::ElectronSeed.setNrLayersAlongTraj(), CaloSD.setNumberCheckedHits(), PFPileUpAlgo.setNumOfPUVtxsForCharged(), edm::service::ResourceInformationService.setNvidiaDriverVersion(), fit::RootMinuit< Function >.setParameter(), CaloSD.setParameterized(), fit::RootMinuit< Function >.setParameters(), SiPixelCalibDigiProducer.setPattern(), SimBeamSpotObjects.setPhi(), Conv4HitsReco2.SetPhiECut(), CmsShowMainBase.setPlayDelay(), CmsShowMainFrame.setPlayDelayGUI(), edm::StoredProcessBlockHelper.setProcessBlockCacheIndices(), edm::ProcessBlockHelperBase.setProcessesWithProcessBlockProducts(), edm::StoredProcessBlockHelper.setProcessesWithProcessBlockProducts(), HiEvtPlaneFlatten.setPt2DB(), HiEvtPlaneFlatten.setPtDB(), reco::HFValueStruct.setPUIntercept(), EcalHitMaker.setPulledPadSurvivalProbability(), reco::HFValueStruct.setPUSlope(), Conv4HitsReco2.SetRadiusECut(), ElectronLimiter.SetRangeCheckFlag(), Conv4HitsReco2.SetRECut(), ALIUtils.setReportVerbosity(), l1t::GlobalBoard.setResetPSCountersEachLumiSec(), L1MuKBMTrack.setResidual(), SteppingHelixPropagator.setReturnTangentPlane(), edm::RunProcessingStatus.setRunPrincipal(), StEvtSolution.setScanValues(), l1t::GlobalBoard.setSemiRandomInitialPSCounters(), SteppingHelixPropagator.setSendLogWarning(), TritonData< IO >.setShape(), Measurement.setSigma(), reco::PFCandidateElectronExtra.setSigmaEtaEta(), reco::PFCandidateEGammaExtra.setSigmaEtaEta(), SimBeamSpotObjects.setSigmaX(), SimBeamSpotObjects.setSigmaY(), BeamSpotObjects.setSigmaZ(), SimBeamSpotObjects.setSigmaZ(), TtFullLeptonicEvent.setSolWeight(), EcalTPGCrystalStatusCode.setStatusCode(), edm::RunProcessingStatus.setStopBeforeProcessingRun(), CrystalPad.setSurvivalProbability(), TimingSD.setTimeFactor(), SimBeamSpotObjects.setTimeOffset(), reco::PFBlockElementSuperCluster.setTrackIso(), DTConfigTSPhi.setTsmStatus(), DTConfigTSPhi.setUsedTraco(), SteppingHelixPropagator.setUseInTeslaFromMagField(), SteppingHelixPropagator.setUseIsYokeFlag(), SteppingHelixPropagator.setUseMagVolumes(), CaloSD.setUseMap(), SteppingHelixPropagator.setUseMatVolumes(), SteppingHelixPropagator.setUseTuningForL2Speed(), MELaserPrim.setVal(), FWIntValueListenerBase.setValue(), EcalTPGStripStatus.setValue(), EcalTPGTowerStatus.setValue(), EcalTPGSpike.setValue(), CalibCoeff.setValue(), L1MonitorDigi.setValue(), Entry.setValue(), edm::TrieNode< T >.setValue(), L1GctInternHFData.setValue(), edm::AssociationVector< KeyRefProd, CVal, KeyRef, SizeType, KeyReferenceHelper >.setValue(), L1GctInternEtSum.setValue(), Measurement.setValue(), BaseMVAValueMapProducer< pat::Muon >.setValue(), EntryData.setValueDisplacement(), FWIntValueListener.setValueImp(), reco::PFCandidateElectronExtra.setVariable(), reco::PFCandidateEGammaExtra.setVariable(), SteppingHelixPropagator.setVBFPointer(), CMSSteppingVerbose.setVerbose(), TtFullLeptonicEvent.setWrongCharge(), SimBeamSpotObjects.setX(), Crystal.setX0Back(), HiEvtPlaneFlatten.setXDB(), HiEvtPlaneFlatten.setXoffDB(), SimBeamSpotObjects.setY(), HiEvtPlaneFlatten.setYDB(), HiEvtPlaneFlatten.setYoffDB(), SimBeamSpotObjects.setZ(), FWPFMaths.sgn(), L1GTTInputProducer.sgn(), HFCherenkov.smearNPE(), JanAlignmentAlgorithm.solve(), OMTFSorter< GoldenPatternType >.sortRefHitResults(), SiStripDetVOffBuilder.statusChange(), SSDigitizerAlgorithm.storeSignalShape(), fit::RootMinuitCommands< Function >.string2double(), ElectronEnergyCalibrator.stringToDouble(), HcalDcsValues.subDetOk(), PixelRecoLineRZ.subTIP(), MultipleScatteringX0Data.sumX0atEta(), pat::Jet.tagInfoByType(), dqm::impl::MonitorElement.tagString(), pat::Flags.test(), test_standard(), edmtest::TestESConcurrentSource.TestESConcurrentSource(), edmtest::TestESSource.TestESSource(), GlobalCoordsObtainer.to_two_comp(), DDMapper< G4LogicalVolume *, DDLogicalPart >.toDouble(), ConvertedPhotonProducer.toFConverterP(), ConversionProducer.toFConverterP(), ConvertedPhotonProducer.toFConverterV(), ConversionProducer.toFConverterV(), cms::alpakatools.toString(), DDMapper< G4LogicalVolume *, DDLogicalPart >.toString(), EcalDumpRaw.toString(), TritonClient.TritonClient(), EgammaL1TkIsolation::TrkCuts.TrkCuts(), EleTkIsolFromCands::TrkCuts.TrkCuts(), ALPAKA_ACCELERATOR_NAMESPACE::hcal::reconstruction::mahi.uint_as_float(), UnbinnedLL(), l1t::stage2::GlobalAlgBlkUnpacker.unpack(), l1t::stage2::GlobalExtBlkUnpacker.unpack(), DCCEEEventBlock.unpack(), DCCEBEventBlock.unpack(), logintpack.unpack16log(), logintpack.unpack16logClosed(), logintpack.unpack8log(), logintpack.unpack8logClosed(), KinematicConstrainedVertexUpdator.update(), KinematicConstrainedVertexUpdatorT< nTrk, nConstraint >.update(), jsoncollector::HistoJ< unsigned int >.update(), PixelInactiveAreaFinder.updatePixelDets(), FWLegoEvePFCandidate.updateScale(), FWBoxRecHit.updateScale(), FWLegoCandidate.updateScale(), FWPFLegoRecHit.updateScale(), ALIUtils.val0(), edm::Entry.validate(), PhoMVACut.value(), GsfEleMVACut.value(), edm::eventsetup::impl::AcquireCacheType< TAcquireReturn >.value(), reco::parser::ExpressionVar.value(), edm::eventsetup::impl::AcquireCacheType< std::optional< U > >.value(), edm::eventsetup::impl::AcquireCacheType< std::unique_ptr< U > >.value(), edm::eventsetup::impl::AcquireCacheType< std::shared_ptr< U > >.value(), reco::parser::ExpressionLazyVar.value(), NanoAODDQM::Plot1D.vfill(), vhdl_int_to_signed(), L1GtVmeWriterCore.vmeAddrValueBlock(), magneticfield::volumeHandle.volumeHandle(), CastorCORData.wasMarkAndPassZS(), HcalHTRData.wasMarkAndPassZS(), HcalHTRData.wasMarkAndPassZSTP(), AlcaBeamSpotManager.weight(), BeamMonitorBx.weight(), and HcalPulseShapes.Y11206().

waitingTime

heppy_batch.waitingTime

Definition at line 370 of file heppy_batch.py.