CMS 3D CMS Logo

Functions | Variables
mps_update Namespace Reference

Functions

def fill_time_info (mps_index, status, cpu_time)
 

Variables

 bjobs
 
 condor_h
 
 condor_q
 
 cpu_time = float(match.group(1))ifmatchelse0
 
 cputime_regex = re.compile(r"TheCPUtimeusedis(\d+(\.\d+)?)seconds")
 
string disabled = "DISABLED"
 loop over remaining jobs to see whether they are done More...
 
 end
 check for orphaned jobs More...
 
dictionary htcondor_jobstatus
 mapping of HTCondor status codes to MPS status More...
 
 job_id = job_regex.search(line).group(1)
 
 job_regex = re.compile(r"Job<(\d+?)>,")
 
dictionary job_status = {}
 deal with submitted jobs by looking into output of shell (bjobs/condor_q) More...
 
 lib = mpslib.jobdatabase()
 collect submitted jobs (use 'in' to handle composites, e.g. More...
 
 match = cputime_regex.search(line)
 
 mps_index = submitted_jobs.get(job_id, -1)
 
 results = bjobs.replace(" ","").split("-----------------------")
 
 status = status_regex.search(line).group(1)
 
 status_regex = re.compile(r"Status<([A-Z]+?)>")
 
bool submitted = True
 
dictionary submitted_jobs = {}
 
string theBatchDirectory = "LSFJOB_"
 
 userlog = os.path.join("jobData", lib.JOBDIR[mps_index], "HTCJOB")
 

Function Documentation

def mps_update.fill_time_info (   mps_index,
  status,
  cpu_time 
)
Fill timing info in the database for `mps_index`.

Arguments:
- `mps_index`: index in the MPS database
- `status`: job status
- `cpu_time`: extracted CPU timing information

Definition at line 11 of file mps_update.py.

References createfilelist.int, and str.

11 def fill_time_info(mps_index, status, cpu_time):
12  """Fill timing info in the database for `mps_index`.
13 
14  Arguments:
15  - `mps_index`: index in the MPS database
16  - `status`: job status
17  - `cpu_time`: extracted CPU timing information
18  """
19 
20  cpu_time = int(round(cpu_time)) # care only about seconds for now
21  if status in ("RUN", "DONE"):
22  if cpu_time > 0:
23  diff = cpu_time - lib.JOBRUNTIME[mps_index]
24  lib.JOBRUNTIME[mps_index] = cpu_time
25  lib.JOBHOST[mps_index] = "+"+str(diff)
26  lib.JOBINCR[mps_index] = diff
27  else:
28  lib.JOBRUNTIME[mps_index] = 0
29  lib.JOBINCR[mps_index] = 0
30 
31 
32 
def fill_time_info(mps_index, status, cpu_time)
Definition: mps_update.py:11
#define str(s)

Variable Documentation

mps_update.bjobs
Initial value:
1 = subprocess.check_output(["bjobs", "-l", "-a"],
2  stderr = subprocess.STDOUT)

Definition at line 74 of file mps_update.py.

mps_update.condor_h
Initial value:
1 = subprocess.check_output(["condor_history", job_id, "-limit", "1",
2  "-userlog", userlog,
3  "-af:j", "JobStatus", "RemoteSysCpu"],
4  stderr = subprocess.STDOUT)

Definition at line 134 of file mps_update.py.

mps_update.condor_q
Initial value:
1 = subprocess.check_output(["condor_q", "-af:j",
2  "JobStatus", "RemoteSysCpu"],
3  stderr = subprocess.STDOUT)

Definition at line 66 of file mps_update.py.

int mps_update.cpu_time = float(match.group(1))ifmatchelse0

Definition at line 70 of file mps_update.py.

mps_update.cputime_regex = re.compile(r"TheCPUtimeusedis(\d+(\.\d+)?)seconds")

Definition at line 80 of file mps_update.py.

string mps_update.disabled = "DISABLED"

loop over remaining jobs to see whether they are done

Definition at line 99 of file mps_update.py.

mps_update.end

check for orphaned jobs

Definition at line 103 of file mps_update.py.

dictionary mps_update.htcondor_jobstatus
Initial value:
1 = {"1": "PEND", # Idle
2  "2": "RUN", # Running
3  "3": "EXIT", # Removed
4  "4": "DONE", # Completed
5  "5": "PEND", # Held
6  "6": "RUN", # Transferring output
7  "7": "PEND"}

mapping of HTCondor status codes to MPS status

Definition at line 35 of file mps_update.py.

mps_update.job_id = job_regex.search(line).group(1)

Definition at line 70 of file mps_update.py.

mps_update.job_regex = re.compile(r"Job<(\d+?)>,")

Definition at line 78 of file mps_update.py.

dictionary mps_update.job_status = {}

deal with submitted jobs by looking into output of shell (bjobs/condor_q)

Definition at line 64 of file mps_update.py.

mps_update.lib = mpslib.jobdatabase()

collect submitted jobs (use 'in' to handle composites, e.g.

DISABLEDFETCH)

Definition at line 46 of file mps_update.py.

mps_update.match = cputime_regex.search(line)

Definition at line 90 of file mps_update.py.

mps_update.mps_index = submitted_jobs.get(job_id, -1)

Definition at line 97 of file mps_update.py.

mps_update.results = bjobs.replace(" ","").split("-----------------------")

Definition at line 82 of file mps_update.py.

Referenced by L1TriggerJSONMonitoring.analyze(), HLTriggerJSONMonitoring.analyze(), HcalTrigTowerGeometry.detIds(), L1TStage2CaloLayer2Offline.doesNotOverlapWithHLTObjects(), TriggerBxMonitor.dqmAnalyze(), TriggerRatesMonitor.dqmAnalyze(), ESElectronicsSim.encode(), LA_Filler_Fitter.ensemble_results(), edm::storage::StatisticsSenderService.filePreCloseEvent(), PulseShapeFitOOTPileupCorrection.fit(), MuScleFitUtils.fitMass(), MuScleFitUtils.fitReso(), for_each_token(), dqmoffline::l1t.getFiredTriggerIndices(), dqmoffline::l1t.getHLTFilters(), CSCWireHitSim.getIonizationClusters(), edm::LuminosityBlock.getManyByType(), edm::Run.getManyByType(), edm::PrincipalGetAdapter.getManyByType(), edm::Event.getManyByType(), dqmoffline::l1t.getMatchedTriggerObjects(), PhysicsTools::LeastSquares.getMeans(), OMTFReconstruction.getProcessorCandidates(), edm::Event.getRefBeforePut(), GlobalMuonRefitter.getRidOfSelectStationHits(), dqmoffline::l1t.getTriggerObjects(), dqmoffline::l1t.getTriggerResults(), PhysicsTools::LeastSquares.getWeights(), edm::PrincipalGetAdapter.isComplete(), LA_Filler_Fitter.layer_results(), L1TEGammaOffline.matchesAnHLTObject(), LA_Filler_Fitter.module_results(), CSCTFAlignmentOnlineProd.newObject(), CSCTFConfigOnlineProd.newObject(), L1MuCSCPtLutConfigOnlineProd.newObject(), L1GctJetFinderParamsOnlineProd.newObject(), L1MuGMTChannelMaskOnlineProducer.newObject(), L1GtPrescaleFactorsAlgoTrigConfigOnlineProd.newObject(), L1GtParametersConfigOnlineProd.newObject(), L1GtPrescaleFactorsTechTrigConfigOnlineProd.newObject(), L1GtTriggerMaskAlgoTrigConfigOnlineProd.newObject(), L1GtTriggerMaskTechTrigConfigOnlineProd.newObject(), L1GtTriggerMaskVetoTechTrigConfigOnlineProd.newObject(), ESRecHitSimAlgo.oldEvalAmplitude(), ESRecHitSimAlgo.oldreconstruct(), dqmoffline::l1t.passesAnyTriggerFromList(), edm::Principal.prodGetter(), CalibratedPhotonProducerT< T >.produce(), CalibratedElectronProducerT< T >.produce(), MuIsolatorResultProducer< BT >.produce(), NuclearInteractionSimulator.read(), fastsim::NuclearInteraction.read(), ESRecHitSimAlgo.reconstruct(), ESRecHitAnalyticAlgo.reconstruct(), ESRecHitFitAlgo.reconstruct(), PVFitter.runFitter(), TotemTimingRecHitProducerAlgorithm.simplifiedLinearRegression(), SiStripClusterInfo.stripNoisesRescaledByGain(), LA_Filler_Fitter.summarize_ensembles(), L1GtTriggerMenuConfigOnlineProd.tableMenuGeneralFromDB(), topLevelPSet(), HcalTrigTowerGeometry.towerIds(), sistrip::MeasureLA.write_report_text(), MuIsolatorResultProducer< BT >.writeOut(), and XMLConfigWriter.writeResultsData().

mps_update.status = status_regex.search(line).group(1)

Definition at line 70 of file mps_update.py.

Referenced by XMLProcessor._toXMLCh(), addFilesWithFork(), ESTimingTask.analyze(), TKStatus.analyze(), CSCTFAnalyzer.analyze(), BeamSpotProblemMonitor.analyze(), DTNoiseCalibration.analyze(), BasicHepMCValidation.analyze(), TotemRPDQMSource.analyze(), MCEfficiencyAnalyzer.analyze(), WriteL1TriggerObjectsTxt.analyze(), L1TCSCTF.analyze(), L1Validator.analyze(), CTPPSDiamondDQMSource.analyze(), HLTriggerJSONMonitoring.analyze(), FWCaloDataHistProxyBuilder.assertCaloDataSlice(), gen::PhotosInterface.attachParticles(), edm::EventProcessor.beginLumiAsync(), EcalBoundaryInfoCalculator< EcalDetId >.boundaryRecHits(), gen::AMPTHadronizer.build_ampt(), TtSemiLepHypHitFit.buildHypo(), TtSemiLepHypKinFit.buildHypo(), TtFullHadHypKinFit.buildHypo(), CaloGeometryHelper.buildNeighbourArray(), PFMETBenchmark.calculateQuantities(), EcalRecHitWorkerRecover.checkChannelStatus(), pat::UserData.checkDictionaries(), QTestStatusChecker.checkGlobalStatus(), lhef::LHEEvent.checkHepMCTree(), HFTimingTrust.checkHFTimErr(), SiPixelFedCablingTree.checkNumbering(), EcalBoundaryInfoCalculator< EBDetId >.checkRecHitHasDeadNeighbour(), EgammaHLTNxNClusterProducer.checkStatusOfEcalRecHit(), HLTEcalResonanceFilter.checkStatusOfEcalRecHit(), HLTRegionalEcalResonanceFilter.checkStatusOfEcalRecHit(), tensorflow.closeSession(), NuclearVertexBuilder.closestApproach(), edm::service.cmssw_stacktrace_fork(), compare_l1candidate(), dtCalibration::DTVDriftSegment.compute(), HFShower.compute(), HDShower.compute(), EMShower.compute(), EcalHitMaker.configureGeometry(), edm::EventProcessor.continueLumiAsync(), ErrorChecker.conversionError(), ErrorCheckerPhase0.conversionError(), dtCalibration::DTTTrigFillWithAverage.correction(), dtCalibration::DTTTrigMatchRPhi.correction(), dtCalibration::DTT0FillDefaultFromDB.correction(), dtCalibration::DTTTrigConstantShift.correction(), dtCalibration::DTT0AbsoluteReferenceCorrection.correction(), dtCalibration::DTT0ChamberReferenceCorrection.correction(), dtCalibration::DTT0FEBPathCorrection.correction(), dtCalibration::DTT0FillChamberFromDB.correction(), dtCalibration::DTTTrigT0SegCorrection.correction(), dtCalibration::DTT0WireInChamberReferenceCorrection.correction(), dtCalibration::DTTTrigResidualCorrection.correction(), TMatacq.countBadPulses(), CounterChecker.CounterChecker(), tensorflow.createSession(), CSCDCCFormatStatusDigi.CSCDCCFormatStatusDigi(), DDIsValid(), gen::TauolappInterface.decay(), LzmaFile.DecodeAll(), LzmaFile.DecodeBuffer(), dtCalibration::DTT0AbsoluteReferenceCorrection.defaultT0(), dtCalibration::DTT0ChamberReferenceCorrection.defaultT0(), dtCalibration::DTT0FEBPathCorrection.defaultT0(), dtCalibration::DTT0WireInChamberReferenceCorrection.defaultT0(), Demangle.Demangle(), EcalHitMaker.diagonalEdge(), doBZ2Compression(), edm::EDLooperBase.doDuringLoop(), PulseChiSqSNNLS.DoFit(), SiPixelGainCalibrationAnalysis.doFits(), EmissionVetoHook1.doVetoFSREmission(), EmissionVetoHook1.doVetoISREmission(), doZlibCompression(), TKStatus.dumpTkDcsStatus(), PFECALHashNavigator.ecalNeighbArray(), DTVDriftWriter.endJob(), DTT0Correction.endJob(), DTTTrigCorrection.endJob(), edm::EventProcessor.endOfLoop(), TMatacq.enterdata(), ErrorChecker.errorDetId(), ErrorCheckerPhase0.errorDetId(), ESRecHitAnalyticAlgo.EvalAmplitude(), ESRecHitFitAlgo.EvalAmplitude(), ESRecHitSimAlgo.evalAmplitude(), PhysicsTools::MVAComputer.evalInternal(), ExternalLHEProducer.executeScript(), EcalHitMaker.fastInsideCell(), MuScleFitPlotter.fillGen(), Py8toJetInput.fillJetAlgoInput(), LHETablesProducer.fillLHEObjectTable(), PFElectronTranslator.fillMVAValueMap(), TrackingQualityChecker.fillTrackingStatus(), TrackingQualityChecker.fillTrackingStatusAtLumi(), PythiaFilterIsolatedTrack.filter(), PythiaFilterTTBar.filter(), EcalDeadCellBoundaryEnergyFilter.filter(), Phase2Tracker::Phase2TrackerFEDBuffer.findChannels(), HepMCValidationHelper.findFSRPhotons(), L1GtVhdlWriterCore.findObjectType(), GenParticlesHelper.findParticles(), edm::Path.finished(), UnbinnedLikelihoodFit.fit(), TtFullHadKinFitter::KinFit.fit(), BSFitter.Fit_d0phi(), reco::GenParticle.fromHardProcessFinalState(), Phase2Tracker::Phase2TrackerFEDHeader.frontendStatus(), EcalBoundaryInfoCalculator< EcalDetId >.gapRecHits(), GaussianTailNoiseGenerator.GaussianTailNoiseGenerator(), GaussNoiseProducerFP420.generate(), GaussianTailNoiseGenerator.generate(), gen::BaseHadronizer.generateLHE(), reco::GenParticle.GenParticle(), pat::PATObject< ObjectType >.genParticleById(), pat::PATObject< reco::Muon >.genParticleRef(), DTTtrig.get(), DTMtime.get(), XrdAdaptor::ClientRequest.get_future(), Py8toJetInput.getAncestor(), dtCalibration::DTTTrigFillWithAverage.getAverage(), ESTrivialConditionRetriever.getChannelStatusFromConfiguration(), EcalTrivialConditionRetriever.getChannelStatusFromConfiguration(), EcalDeadCellTriggerPrimitiveFilter.getChannelStatusMaps(), EcalDeadCellDeltaRFilter.getChannelStatusMaps(), FWGUIManager.getContext(), pat::EventHypothesis.getDemangledSymbol(), cscdqm::Summary.GetEfficiencyHW(), PixelSLinkDataInputSource.getEventNumberFromFillWords(), HLTTauMCProducer.getGenDecayProducts(), XrdAdaptor::RequestManager.getInstance(), SiPixelInformationExtractor.getItemValue(), CrossingPtBasedLinearizationPointFinder.getLinearizationPoint(), TrackingUtility.getMEStatus(), SiStripUtility.getMEStatus(), DTDeadFlagHandler.getNewObjects(), DTPerformanceHandler.getNewObjects(), DTRangeT0Handler.getNewObjects(), DTReadOutMappingHandler.getNewObjects(), DTStatusFlagHandler.getNewObjects(), DTT0Handler.getNewObjects(), DTTPGParametersHandler.getNewObjects(), FedRawDataInputSource.getNextEvent(), cscdqm::Summary.GetReportingArea(), SiPixelUtility.getStatus(), DQMStore.getStatus(), SiPixelUtility.getStatusColor(), EcalTrivialConditionRetriever.getTrgChannelStatusFromConfiguration(), edm::EventProcessor.globalEndLumiAsync(), XrdAdaptor::Source.handle(), edm::Path.handleEarlyFinish(), edm::EventProcessor.handleNextEventForStreamAsync(), MakerResponseHandler.HandleResponse(), XrdAdaptor::ClientRequest.HandleResponse(), SendMonitoringInfoHandler.HandleResponse(), DelayedClose.HandleResponseWithHosts(), XrdAdaptor::RequestManager::OpenHandler.HandleResponseWithHosts(), EgammaHadTower.hasActiveHcal(), GenParticlesHelper.hasAncestor(), CalorimetryManager.HDShowerSimulation(), Generator.HepMC2G4(), HcalHFStatusBitFromRecHits.hfSetFlagFromRecHits(), InduceChargeFP420.induce(), PFBadHcalPseudoClusterProducer.init(), fireworks::Context.initEveElements(), RBCBasicConfig.initialise(), TTUBasicConfig.initialise(), RBCEmulator.initialise(), RPCWheel.initialise(), LogicTool< GenLogic >.initialise(), TTUEmulator.initialise(), XrdAdaptor::RequestManager.initialize(), Pythia8Hadronizer.initializeForExternalPartons(), Pythia8Hadronizer.initializeForInternalPartons(), edm::ParameterDescriptionCases< T >.insert(), edm::ParameterSwitchBase.insertAndCheckLabels(), MBUEandQCDValidation.isCharged(), HepMCValidationHelper.isChargedLepton(), EcalDeadCellDeltaRFilter.isCloseToBadEcalChannel(), AnomalousECALVariables.isDeadEcalCluster(), GenParticlesHelper.isDirect(), reco::GenParticle.isDirectHardProcessTauDecayProductFinalState(), reco::GenParticle.isDirectPromptTauDecayProductFinalState(), MBUEandQCDValidation.isNeutral(), HepMCValidationHelper.isNeutrino(), MBUEandQCDValidation.isNeutrino(), npstat.isNonDecreasing(), npstat.isNonIncreasing(), cscdqm::Summary.IsPhysicsReady(), reco::GenParticle.isPromptFinalState(), npstat.isStrictlyDecreasing(), AbsHcalFunctor.isStrictlyDecreasing(), npstat.isStrictlyIncreasing(), AbsHcalFunctor.isStrictlyIncreasing(), FFTJetProducer.iterateJetReconstruction(), reco::PFCandidateElectronExtra.kfTrackRef(), tensorflow.loadGraphDef(), tensorflow.loadMetaGraph(), PFRecoTauDiscriminationAgainstElectronDeadECAL.loopXtals(), main(), lhef::LHEEvent.makeHepMCParticle(), gen.GeneratorAnalyzer.GeneratorAnalyzer.makeMCInfo(), EcalUncalibRecHitMultiFitAlgo.makeRecHit(), reco::MCMatchSelector< T1, T2 >.MCMatchSelector(), MergeRootfile(), PulseChiSqSNNLS.Minimize(), CaloGeometryHelper.move(), FedRawDataInputSource.nextEvent(), tensorflow::NTSession.NTSession(), ESRecHitSimAlgo.oldEvalAmplitude(), ESRecHitSimAlgo.oldreconstruct(), XrdFile.open(), XrdAdaptor::RequestManager::OpenHandler.open(), TEcnaRead.OpenRootFile(), TEcnaRun.OpenRootFile(), TSCBLBuilderNoMaterial.operator()(), GenJetParticleSelector.operator()(), FastTimerService::ResourcesPerPath.operator+=(), trigger::TriggerObject.particle(), FFTJetCorrectionProducer.performPileupSubtraction(), pos::PixelDetectorConfig.PixelDetectorConfig(), PixelTemplateSmearerBase.PixelTemplateSmearerBase(), SymmetryFit.pol2_from_pol2(), SymmetryFit.pol2_from_pol3(), edm::OccurrenceTraits< EventPrincipal, BranchActionStreamBegin >.postPathSignal(), EPOS::EPOS_Wrapper.print_hepcom_particle(), HepMCFileReader.printEvent(), TMatacq.printitermatacqData(), RBCChamberORLogic.process(), RPCWheel.process(), edm::EventProcessor.processEventWithLooper(), WeakEffectsWeightProducer.produce(), PseudoTopProducer.produce(), TtSemiLepKinFitProducer< LeptonCollection >.produce(), ISRGammaWeightProducer.produce(), ISRWeightProducer.produce(), PdfWeightProducer.produce(), PFElectronTranslator.produce(), RPCUnpackingModule.produce(), CSCTFUnpacker.produce(), Onia2MuMuPAT.produce(), PFPhotonTranslator.produce(), FlavorHistoryProducer.produce(), l1t::GenToInputProducer.produce(), RPCTechnicalTrigger.produce(), FFTJetProducer.produce(), HcalHardcodeCalibrations.produceChannelQuality(), EcalTrivialConditionRetriever.produceEcalDAQTowerStatus(), EcalTrivialConditionRetriever.produceEcalDCSTowerStatus(), ecaldqm::CalibrationSummaryClient.producePlots(), ecaldqm::SummaryClient.producePlots(), Herwig6Hadronizer.pythiaStatusCode(), StoreEcalCondition.readEcalChannelStatusFromFile(), StoreESCondition.readESChannelStatusFromFile(), DTReadOutMapping.readOutToGeometry(), FedRawDataInputSource.readSupervisor(), IOInput.readv(), EcalDCSTowerStatusXMLTranslator.readXML(), EcalDAQTowerStatusXMLTranslator.readXML(), ESRecHitAnalyticAlgo.reconstruct(), ESRecHitSimAlgo.reconstruct(), ESRecHitFitAlgo.reconstruct(), XrdAdaptor::RequestManager.requestFailure(), FastTimerService::ResourcesPerPath.reset(), gen::Cascade2Hadronizer.residualDecay(), gen::Pythia6Hadronizer.residualDecay(), TEcnaRootFile.ReStart(), L1GtVhdlWriterCore.returnConditionsOfOneClass(), dqmservices::TriggerSelector::TreeElement.returnStatus(), Pythia8PartonSelector.run(), tensorflow.run(), run_script(), ecaldqm::RawDataTask.runOnRawData(), DQMStore.saveMonitorElementRangeToROOT(), HcalSourcePositionData.set(), DTStatusFlag.setCellDead(), DTDeadFlag.setCellDead_HV(), DTDeadFlag.setCellDead_RO(), DTDeadFlag.setCellDead_TP(), DTDeadFlag.setCellDiscCat(), DTStatusFlag.setCellFEMask(), DTStatusFlag.setCellNoHV(), DTStatusFlag.setCellNoise(), DTStatusFlag.setCellTDCMask(), DTStatusFlag.setCellTrigMask(), ESRecHitSimAlgo.setChannelStatus(), ESRecHitAnalyticAlgo.setChannelStatus(), ESRecHitFitAlgo.setChannelStatus(), FWLegoViewBase.setContext(), EcalDeadCellTriggerPrimitiveFilter.setEvtRecHitstatus(), EcalDeadCellTriggerPrimitiveFilter.setEvtTPstatus(), ESDigitizer.setGain(), EcalTBHodoscopePlaneRawHits.setHit(), reco::CSCHaloData.SetHLTBit(), FFTJetProducer.setJetStatusBit(), gen::TauolappInterface.setRandomEngine(), MonDelaysTTDat.setTaskStatus(), MonPedestalsOnlineDat.setTaskStatus(), MonPedestalOffsetsDat.setTaskStatus(), MonLaserGreenDat.setTaskStatus(), MonLaserBlueDat.setTaskStatus(), MonLaserRedDat.setTaskStatus(), MonPNPedDat.setTaskStatus(), MonLaserIRedDat.setTaskStatus(), MonLed1Dat.setTaskStatus(), MonLed2Dat.setTaskStatus(), MonCrystalConsistencyDat.setTaskStatus(), MonMemChConsistencyDat.setTaskStatus(), MonPedestalsDat.setTaskStatus(), MonTestPulseDat.setTaskStatus(), MonTTConsistencyDat.setTaskStatus(), MonMemTTConsistencyDat.setTaskStatus(), MonPNRedDat.setTaskStatus(), MonPNLed1Dat.setTaskStatus(), MonPNLed2Dat.setTaskStatus(), MonPNBlueDat.setTaskStatus(), MonPNIRedDat.setTaskStatus(), MonPNMGPADat.setTaskStatus(), MonPNGreenDat.setTaskStatus(), ITimingDat.setTaskStatus(), HBHETimingShapedFlagSetter.SetTimingShapedFlags(), reco::PFCandidateEGammaExtra.singleLegConversionRef(), XrdStorageMaker.stagein(), edm::EventProcessor.streamEndLumiAsync(), SymmetryFit.symmetryChi2(), tensorflow::TBBSession.TBBSession(), TEcnaRootFile.TEcnaRootFile(), CSCFitAFEBThr.ThresholdNoise(), HBHETimingShapedFlagSetter.timingStatus(), TMatacq.TMatacq(), HLTPerformanceInfo.totalPathCPUTime(), HLTPerformanceInfo.totalPathTime(), edm.typeDemangle(), pat::UserData.typeNameFor(), edm::UnscheduledProductResolver.unscheduledWasNotRun_(), HcaluLUTTPGCoder.update(), edm::service::CondorStatusService.updateChirpImpl(), PulseChiSqSNNLS.updateCov(), CrossingPtBasedLinearizationPointFinder.useAllTracks(), tensorflow::TBBSession.WaitForNotification(), tensorflow::NTSession.WaitForNotification(), PixelDataFormatter.word2digi(), cscdqm::Summary.Write(), npstat::LinInterpolatedTableND< Numeric, Axis >.write(), EPOS::IO_EPOS.write_event(), gs.writeCompressedStringArchive(), gs.writeStringArchive(), CrystalWindowMap.~CrystalWindowMap(), and ErrorCheckerBase.~ErrorCheckerBase().

mps_update.status_regex = re.compile(r"Status<([A-Z]+?)>")

Definition at line 79 of file mps_update.py.

bool mps_update.submitted = True

Definition at line 51 of file mps_update.py.

dictionary mps_update.submitted_jobs = {}

Definition at line 49 of file mps_update.py.

string mps_update.theBatchDirectory = "LSFJOB_"

Definition at line 124 of file mps_update.py.

mps_update.userlog = os.path.join("jobData", lib.JOBDIR[mps_index], "HTCJOB")

Definition at line 133 of file mps_update.py.