CMS 3D CMS Logo

List of all members | Public Member Functions | Public Attributes
upgradeWorkflowComponents.UpgradeWorkflow Class Reference
Inheritance diagram for upgradeWorkflowComponents.UpgradeWorkflow:
upgradeWorkflowComponents.PatatrackWorkflow upgradeWorkflowComponents.UpgradeWorkflow_0T upgradeWorkflowComponents.UpgradeWorkflow_baseline upgradeWorkflowComponents.UpgradeWorkflow_DD4hep upgradeWorkflowComponents.UpgradeWorkflow_DD4hepDB upgradeWorkflowComponents.UpgradeWorkflow_DDDDB upgradeWorkflowComponents.UpgradeWorkflow_DigiNoHLT upgradeWorkflowComponents.UpgradeWorkflow_ecalclustering upgradeWorkflowComponents.UpgradeWorkflow_ECalComponent upgradeWorkflowComponents.UpgradeWorkflow_ecalDevel upgradeWorkflowComponents.UpgradeWorkflow_HeavyFlavor upgradeWorkflowComponents.UpgradeWorkflow_heCollapse upgradeWorkflowComponents.UpgradeWorkflow_HLT75e33 upgradeWorkflowComponents.UpgradeWorkflow_HLTwDIGI75e33 upgradeWorkflowComponents.UpgradeWorkflow_ITSignalShape upgradeWorkflowComponents.UpgradeWorkflow_JMENano upgradeWorkflowComponents.UpgradeWorkflow_L1Complete upgradeWorkflowComponents.UpgradeWorkflow_mlpf upgradeWorkflowComponents.UpgradeWorkflow_Neutron upgradeWorkflowComponents.UpgradeWorkflow_OTInefficiency upgradeWorkflowComponents.UpgradeWorkflow_ParkingBPH upgradeWorkflowComponents.UpgradeWorkflow_Phase2_HeavyIon upgradeWorkflowComponents.UpgradeWorkflow_photonDRN upgradeWorkflowComponents.UpgradeWorkflow_ProdLike upgradeWorkflowComponents.UpgradeWorkflow_Run3FSMBMixing upgradeWorkflowComponents.UpgradeWorkflow_Run3FStrackingOnly upgradeWorkflowComponents.UpgradeWorkflow_seedingDeepCore upgradeWorkflowComponents.UpgradeWorkflow_SonicTriton upgradeWorkflowComponents.UpgradeWorkflow_ticl_clue3D upgradeWorkflowComponents.UpgradeWorkflow_ticl_FastJet upgradeWorkflowComponents.UpgradeWorkflow_ticl_v5 upgradeWorkflowComponents.UpgradeWorkflow_ticl_v5_superclustering upgradeWorkflowComponents.UpgradeWorkflow_trackdnn upgradeWorkflowComponents.UpgradeWorkflow_vectorHits upgradeWorkflowComponents.UpgradeWorkflow_weightedVertex upgradeWorkflowComponents.UpgradeWorkflowAging upgradeWorkflowComponents.UpgradeWorkflowPremix upgradeWorkflowComponents.UpgradeWorkflowTracking

Public Member Functions

def __init__ (self, steps, PU, suffix, offset)
 
def condition (self, fragment, stepList, key, hasHarvest)
 
def getStepName (self, step, extra="")
 
def getStepNamePU (self, step, extra="")
 
def init (self, stepDict)
 
def preventReuse (self, stepName, stepDict, k)
 
def setup (self, stepDict, k, properties)
 
def setup_ (self, step, stepName, stepDict, k, properties)
 
def setupPU (self, stepDict, k, properties)
 
def setupPU_ (self, step, stepName, stepDict, k, properties)
 
def workflow (self, workflows, num, fragment, stepList, key, hasHarvest)
 
def workflow_ (self, workflows, num, fragment, stepList, key)
 

Public Attributes

 allowReuse
 
 offset
 
 PU
 
 steps
 
 suffix
 

Detailed Description

Definition at line 120 of file upgradeWorkflowComponents.py.

Constructor & Destructor Documentation

◆ __init__()

def upgradeWorkflowComponents.UpgradeWorkflow.__init__ (   self,
  steps,
  PU,
  suffix,
  offset 
)

Definition at line 121 of file upgradeWorkflowComponents.py.

121  def __init__(self,steps,PU,suffix,offset):
122  self.steps = steps
123  self.PU = PU
124  self.allowReuse = True
125 
126  # ensure all PU steps are in normal step list
127  for step in self.PU:
128  if not step in self.steps:
129  self.steps.append(step)
130 
131  self.suffix = suffix
132  if len(self.suffix)>0 and self.suffix[0]!='_': self.suffix = '_'+self.suffix
133  self.offset = offset
134  if self.offset < 0.0 or self.offset > 1.0:
135  raise ValueError("Special workflow offset must be between 0.0 and 1.0")
def __init__(self, dataset, job_number, job_id, job_name, isDA, isMC, applyBOWS, applyEXTRACOND, extraconditions, runboundary, lumilist, intlumi, maxevents, gt, allFromGT, alignmentDB, alignmentTAG, apeDB, apeTAG, bowDB, bowTAG, vertextype, tracktype, refittertype, ttrhtype, applyruncontrol, ptcut, CMSSW_dir, the_dir)

Member Function Documentation

◆ condition()

def upgradeWorkflowComponents.UpgradeWorkflow.condition (   self,
  fragment,
  stepList,
  key,
  hasHarvest 
)

Definition at line 170 of file upgradeWorkflowComponents.py.

170  def condition(self, fragment, stepList, key, hasHarvest):
171  return False

◆ getStepName()

def upgradeWorkflowComponents.UpgradeWorkflow.getStepName (   self,
  step,
  extra = "" 
)

◆ getStepNamePU()

def upgradeWorkflowComponents.UpgradeWorkflow.getStepNamePU (   self,
  step,
  extra = "" 
)

Definition at line 139 of file upgradeWorkflowComponents.py.

References upgradeWorkflowComponents.UpgradeWorkflow.suffix.

Referenced by upgradeWorkflowComponents.UpgradeWorkflow.init(), and upgradeWorkflowComponents.UpgradeWorkflow.setupPU().

139  def getStepNamePU(self, step, extra=""):
140  stepNamePU = step + 'PU' + self.suffix + extra
141  return stepNamePU

◆ init()

def upgradeWorkflowComponents.UpgradeWorkflow.init (   self,
  stepDict 
)

Definition at line 142 of file upgradeWorkflowComponents.py.

References upgradeWorkflowComponents.UpgradeWorkflow.allowReuse, upgradeWorkflowComponents.UpgradeWorkflow.getStepName(), upgradeWorkflowComponents.UpgradeWorkflow.getStepNamePU(), upgradeWorkflowComponents.UpgradeWorkflow.PU, HitEff.PU, MatrixUtil.WF.steps, and upgradeWorkflowComponents.UpgradeWorkflow.steps.

142  def init(self, stepDict):
143  for step in self.steps:
144  stepDict[self.getStepName(step)] = {}
145  if not self.allowReuse: stepDict[self.getStepName(step,preventReuseKeyword)] = {}
146  for step in self.PU:
147  stepDict[self.getStepNamePU(step)] = {}
148  if not self.allowReuse: stepDict[self.getStepNamePU(step,preventReuseKeyword)] = {}
int init
Definition: HydjetWrapper.h:66

◆ preventReuse()

def upgradeWorkflowComponents.UpgradeWorkflow.preventReuse (   self,
  stepName,
  stepDict,
  k 
)

Definition at line 172 of file upgradeWorkflowComponents.py.

Referenced by upgradeWorkflowComponents.UpgradeWorkflow.setup(), and upgradeWorkflowComponents.UpgradeWorkflow.setupPU().

172  def preventReuse(self, stepName, stepDict, k):
173  if "Sim" in stepName and stepName != "Sim":
174  stepDict[stepName][k] = None
175  if "Gen" in stepName:
176  stepDict[stepName][k] = None

◆ setup()

def upgradeWorkflowComponents.UpgradeWorkflow.setup (   self,
  stepDict,
  k,
  properties 
)

Definition at line 149 of file upgradeWorkflowComponents.py.

References upgradeWorkflowComponents.UpgradeWorkflow.allowReuse, upgradeWorkflowComponents.UpgradeWorkflow.getStepName(), upgradeWorkflowComponents.UpgradeWorkflow.preventReuse(), TrackFinder.setup_, trackerDTC::LayerEncoding.setup_, trackerTFP::GeometricProcessor.setup_, trackerTFP::ZHoughTransform.setup_, trackerDTC::Stub.setup_, trackerTFP::LayerEncoding.setup_, trackerTFP::MiniHoughTransform.setup_, trackerDTC::DTC.setup_, trackerTFP::HoughTransform.setup_, trackerDTC::ProducerED.setup_, tt::StubAssociation.setup_, trklet::ProducerAS.setup_, trackerTFP::ProducerZHTout.setup_, SectorProcessor.setup_, trackerTFP::KalmanFilter.setup_, trklet::ProducerTT.setup_, trackerTFP::ProducerTT.setup_, trackerTFP::ProducerHT.setup_, trackerTFP::ProducerMHT.setup_, trackerTFP::ProducerZHT.setup_, trackerTFP::ProducerGP.setup_, trklet::DR.setup_, trklet::ProducerKFout.setup_, l1t::L1TDigiToRaw.setup_, trklet::ProducerDR.setup_, trackerTFP::ProducerKFin.setup_, trackerTFP::ProducerKF.setup_, trklet::ProducerKFin.setup_, trklet::ProducerTBout.setup_, trklet::ProducerDRin.setup_, ALPAKA_ACCELERATOR_NAMESPACE::device::EventSetup.setup_, trklet::ChannelAssignment.setup_, trklet::KFin.setup_, trackerTFP::State.setup_, hph::HitPatternHelper.setup_, trklet::TrackletLUT.setup_, trklet::DRin.setup_, CandCombiner< Selector, PairSelector, Cloner, OutputCollection, Setup >.setup_, upgradeWorkflowComponents.UpgradeWorkflow.setup_(), trackerTFP::KalmanFilterFormats.setup_, L1FPGATrackProducer.setup_, SingleTopTChannelLeptonDQM_miniAOD.setup_, TopSingleLeptonDQM_miniAOD.setup_, TopSingleLeptonDQM.setup_, TopDiLeptonOfflineDQM.setup_, trklet::Settings.setup_, trackerTFP::DataFormats.setup_, MatrixUtil.WF.steps, and upgradeWorkflowComponents.UpgradeWorkflow.steps.

149  def setup(self, stepDict, k, properties):
150  for step in self.steps:
151  self.setup_(step, self.getStepName(step), stepDict, k, properties)
152  if not self.allowReuse: self.preventReuse(self.getStepName(step,preventReuseKeyword), stepDict, k)

◆ setup_()

def upgradeWorkflowComponents.UpgradeWorkflow.setup_ (   self,
  step,
  stepName,
  stepDict,
  k,
  properties 
)

Definition at line 157 of file upgradeWorkflowComponents.py.

Referenced by upgradeWorkflowComponents.UpgradeWorkflow.setup().

157  def setup_(self, step, stepName, stepDict, k, properties):
158  pass

◆ setupPU()

def upgradeWorkflowComponents.UpgradeWorkflow.setupPU (   self,
  stepDict,
  k,
  properties 
)

Definition at line 153 of file upgradeWorkflowComponents.py.

References upgradeWorkflowComponents.UpgradeWorkflow.allowReuse, upgradeWorkflowComponents.UpgradeWorkflow.getStepNamePU(), upgradeWorkflowComponents.UpgradeWorkflow.preventReuse(), upgradeWorkflowComponents.UpgradeWorkflow.PU, HitEff.PU, and upgradeWorkflowComponents.UpgradeWorkflow.setupPU_().

153  def setupPU(self, stepDict, k, properties):
154  for step in self.PU:
155  self.setupPU_(step, self.getStepNamePU(step), stepDict, k, properties)
156  if not self.allowReuse: self.preventReuse(self.getStepNamePU(step,preventReuseKeyword), stepDict, k)

◆ setupPU_()

def upgradeWorkflowComponents.UpgradeWorkflow.setupPU_ (   self,
  step,
  stepName,
  stepDict,
  k,
  properties 
)

Definition at line 159 of file upgradeWorkflowComponents.py.

Referenced by upgradeWorkflowComponents.UpgradeWorkflow.setupPU().

159  def setupPU_(self, step, stepName, stepDict, k, properties):
160  pass

◆ workflow()

def upgradeWorkflowComponents.UpgradeWorkflow.workflow (   self,
  workflows,
  num,
  fragment,
  stepList,
  key,
  hasHarvest 
)

Definition at line 161 of file upgradeWorkflowComponents.py.

161  def workflow(self, workflows, num, fragment, stepList, key, hasHarvest):
162  if self.condition(fragment, stepList, key, hasHarvest):
163  self.workflow_(workflows, num, fragment, stepList, key)

◆ workflow_()

def upgradeWorkflowComponents.UpgradeWorkflow.workflow_ (   self,
  workflows,
  num,
  fragment,
  stepList,
  key 
)

Definition at line 164 of file upgradeWorkflowComponents.py.

References relval_nano.WFN.offset, SiPixelVCal::VCal.offset, sistrip::MeasureLA.offset, upgradeWorkflowComponents.UpgradeWorkflow.offset, PhysicsTools::Calibration::ProcLinear.offset, and upgradeWorkflowComponents.UpgradeWorkflow.suffix.

164  def workflow_(self, workflows, num, fragment, stepList, key):
165  fragmentTmp = [fragment, key]
166  if len(self.suffix)>0: fragmentTmp.append(self.suffix)
167  # avoid spurious workflows (no steps modified)
168  if self.offset==0 or workflows[num][1]!=stepList:
169  workflows[num+self.offset] = [ fragmentTmp, stepList ]

Member Data Documentation

◆ allowReuse

upgradeWorkflowComponents.UpgradeWorkflow.allowReuse

◆ offset

upgradeWorkflowComponents.UpgradeWorkflow.offset

◆ PU

upgradeWorkflowComponents.UpgradeWorkflow.PU

◆ steps

upgradeWorkflowComponents.UpgradeWorkflow.steps

◆ suffix

upgradeWorkflowComponents.UpgradeWorkflow.suffix