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_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.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 90 of file upgradeWorkflowComponents.py.

Constructor & Destructor Documentation

◆ __init__()

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

Definition at line 91 of file upgradeWorkflowComponents.py.

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

138  def condition(self, fragment, stepList, key, hasHarvest):
139  return False

◆ getStepName()

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

◆ getStepNamePU()

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

Definition at line 109 of file upgradeWorkflowComponents.py.

References upgradeWorkflowComponents.UpgradeWorkflow.suffix.

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

109  def getStepNamePU(self, step, extra=""):
110  stepNamePU = step + 'PU' + self.suffix + extra
111  return stepNamePU

◆ init()

def upgradeWorkflowComponents.UpgradeWorkflow.init (   self,
  stepDict 
)

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

112  def init(self, stepDict):
113  for step in self.steps:
114  stepDict[self.getStepName(step)] = {}
115  if not self.allowReuse: stepDict[self.getStepName(step,preventReuseKeyword)] = {}
116  for step in self.PU:
117  stepDict[self.getStepNamePU(step)] = {}
118  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 140 of file upgradeWorkflowComponents.py.

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

140  def preventReuse(self, stepName, stepDict, k):
141  if "Sim" in stepName:
142  stepDict[stepName][k] = None
143  if "Gen" in stepName:
144  stepDict[stepName][k] = None

◆ setup()

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

Definition at line 119 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_, trklet::ProducerKFout.setup_, trackerTFP::ProducerKFin.setup_, trackerTFP::ProducerKF.setup_, trklet::ProducerKFin.setup_, trklet::ProducerTBout.setup_, l1t::L1TDigiToRaw.setup_, ALPAKA_ACCELERATOR_NAMESPACE::device::EventSetup.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.

119  def setup(self, stepDict, k, properties):
120  for step in self.steps:
121  self.setup_(step, self.getStepName(step), stepDict, k, properties)
122  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 127 of file upgradeWorkflowComponents.py.

Referenced by upgradeWorkflowComponents.UpgradeWorkflow.setup().

127  def setup_(self, step, stepName, stepDict, k, properties):
128  pass

◆ setupPU()

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

Definition at line 123 of file upgradeWorkflowComponents.py.

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

123  def setupPU(self, stepDict, k, properties):
124  for step in self.PU:
125  self.setupPU_(step, self.getStepNamePU(step), stepDict, k, properties)
126  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 129 of file upgradeWorkflowComponents.py.

Referenced by upgradeWorkflowComponents.UpgradeWorkflow.setupPU().

129  def setupPU_(self, step, stepName, stepDict, k, properties):
130  pass

◆ workflow()

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

Definition at line 131 of file upgradeWorkflowComponents.py.

131  def workflow(self, workflows, num, fragment, stepList, key, hasHarvest):
132  if self.condition(fragment, stepList, key, hasHarvest):
133  self.workflow_(workflows, num, fragment, stepList, key)

◆ workflow_()

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

Definition at line 134 of file upgradeWorkflowComponents.py.

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

134  def workflow_(self, workflows, num, fragment, stepList, key):
135  fragmentTmp = [fragment, key]
136  if len(self.suffix)>0: fragmentTmp.append(self.suffix)
137  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