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_ecalDevel upgradeWorkflowComponents.UpgradeWorkflow_heCollapse upgradeWorkflowComponents.UpgradeWorkflow_HLT75e33 upgradeWorkflowComponents.UpgradeWorkflow_HLTwDIGI75e33 upgradeWorkflowComponents.UpgradeWorkflow_JMENano upgradeWorkflowComponents.UpgradeWorkflow_mlpf upgradeWorkflowComponents.UpgradeWorkflow_NanoV10 upgradeWorkflowComponents.UpgradeWorkflow_Neutron upgradeWorkflowComponents.UpgradeWorkflow_OTInefficiency upgradeWorkflowComponents.UpgradeWorkflow_ParkingBPH 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_v3 upgradeWorkflowComponents.UpgradeWorkflow_trackdnn upgradeWorkflowComponents.UpgradeWorkflow_vectorHits 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 84 of file upgradeWorkflowComponents.py.

Constructor & Destructor Documentation

◆ __init__()

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

Definition at line 85 of file upgradeWorkflowComponents.py.

85  def __init__(self,steps,PU,suffix,offset):
86  self.steps = steps
87  self.PU = PU
88  self.allowReuse = True
89 
90  # ensure all PU steps are in normal step list
91  for step in self.PU:
92  if not step in self.steps:
93  self.steps.append(step)
94 
95  self.suffix = suffix
96  if len(self.suffix)>0 and self.suffix[0]!='_': self.suffix = '_'+self.suffix
97  self.offset = offset
98  if self.offset < 0.0 or self.offset > 1.0:
99  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 132 of file upgradeWorkflowComponents.py.

132  def condition(self, fragment, stepList, key, hasHarvest):
133  return False

◆ getStepName()

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

◆ getStepNamePU()

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

Definition at line 103 of file upgradeWorkflowComponents.py.

References upgradeWorkflowComponents.UpgradeWorkflow.suffix.

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

103  def getStepNamePU(self, step, extra=""):
104  stepNamePU = step + 'PU' + self.suffix + extra
105  return stepNamePU

◆ init()

def upgradeWorkflowComponents.UpgradeWorkflow.init (   self,
  stepDict 
)

Definition at line 106 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.

106  def init(self, stepDict):
107  for step in self.steps:
108  stepDict[self.getStepName(step)] = {}
109  if not self.allowReuse: stepDict[self.getStepName(step,preventReuseKeyword)] = {}
110  for step in self.PU:
111  stepDict[self.getStepNamePU(step)] = {}
112  if not self.allowReuse: stepDict[self.getStepNamePU(step,preventReuseKeyword)] = {}
int init
Definition: HydjetWrapper.h:64

◆ preventReuse()

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

Definition at line 134 of file upgradeWorkflowComponents.py.

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

134  def preventReuse(self, stepName, stepDict, k):
135  if "Sim" in stepName:
136  stepDict[stepName][k] = None
137  if "Gen" in stepName:
138  stepDict[stepName][k] = None

◆ setup()

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

Definition at line 113 of file upgradeWorkflowComponents.py.

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

113  def setup(self, stepDict, k, properties):
114  for step in self.steps:
115  self.setup_(step, self.getStepName(step), stepDict, k, properties)
116  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 121 of file upgradeWorkflowComponents.py.

Referenced by upgradeWorkflowComponents.UpgradeWorkflow.setup().

121  def setup_(self, step, stepName, stepDict, k, properties):
122  pass

◆ setupPU()

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

Definition at line 117 of file upgradeWorkflowComponents.py.

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

117  def setupPU(self, stepDict, k, properties):
118  for step in self.PU:
119  self.setupPU_(step, self.getStepNamePU(step), stepDict, k, properties)
120  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 123 of file upgradeWorkflowComponents.py.

Referenced by upgradeWorkflowComponents.UpgradeWorkflow.setupPU().

123  def setupPU_(self, step, stepName, stepDict, k, properties):
124  pass

◆ workflow()

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

Definition at line 125 of file upgradeWorkflowComponents.py.

125  def workflow(self, workflows, num, fragment, stepList, key, hasHarvest):
126  if self.condition(fragment, stepList, key, hasHarvest):
127  self.workflow_(workflows, num, fragment, stepList, key)

◆ workflow_()

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

Definition at line 128 of file upgradeWorkflowComponents.py.

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

128  def workflow_(self, workflows, num, fragment, stepList, key):
129  fragmentTmp = [fragment, key]
130  if len(self.suffix)>0: fragmentTmp.append(self.suffix)
131  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