Inheritance diagram for upgradeWorkflowComponents.PatatrackWorkflow:

Public Member Functions
def	__init__ (self, digi={}, reco={}, mini={}, harvest={}, kwargs)

def	condition (self, fragment, stepList, key, hasHarvest)

def	setup_ (self, step, stepName, stepDict, k, properties)

Public Member Functions inherited from upgradeWorkflowComponents.UpgradeWorkflow
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)

Static Public Attributes
	digi

	harvest

	offset

	reco

	suffix

Private Attributes
	__digi

	__harvest

	__mini

	__reco

Additional Inherited Members
Public Attributes inherited from upgradeWorkflowComponents.UpgradeWorkflow
	allowReuse

	offset

	PU

	steps

	suffix

Detailed Description

Definition at line 871 of file upgradeWorkflowComponents.py.

Constructor & Destructor Documentation

◆ init()

def upgradeWorkflowComponents.PatatrackWorkflow.__init__	(	self,
		digi = `{}`,
		reco = `{}`,
		mini = `{}`,
		harvest = `{}`,
		kwargs
	)

Definition at line 872 of file upgradeWorkflowComponents.py.

     def __init__(self, digi = {}, reco = {}, mini = {}, harvest = {}, **kwargs):
         # adapt the parameters for the UpgradeWorkflow init method
         super(PatatrackWorkflow, self).__init__(
             steps = [
                 'Digi',
                 'HLTOnly',
                 'DigiTrigger',
                 'Reco',
                 'RecoFakeHLT',
                 'HARVEST',
                 'HARVESTFakeHLT',
                 'RecoGlobal',
                 'HARVESTGlobal',
                 'RecoNano',
                 'RecoNanoFakeHLT',
                 'HARVESTNano',
                 'HARVESTNanoFakeHLT',
                 'MiniAOD',
                 'Nano',
                 'ALCA',
                 'ALCAPhase2'
             ],
             PU = [
                 'Digi',
                 'HLTOnly',
                 'DigiTrigger',
                 'Reco',
                 'RecoFakeHLT',
                 'HARVEST',
                 'HARVESTFakeHLT',
                 'RecoGlobal',
                 'HARVESTGlobal',
                 'RecoNano',
                 'RecoNanoFakeHLT',
                 'HARVESTNano',
                 'HARVESTNanoFakeHLT',
                 'MiniAOD',
                 'Nano',
                 'ALCA',
                 'ALCAPhase2'
             ],
             **kwargs)
         self.__digi = digi
         self.__reco = reco
         if 'DQM' in self.__reco:
             self.__reco.update({
                 '--datatier':     'GEN-SIM-RECO,DQMIO',
                 '--eventcontent': 'RECOSIM,DQM'
             })
         self.__mini = mini
         self.__harvest = harvest
 

Member Function Documentation

◆ condition()

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

Definition at line 924 of file upgradeWorkflowComponents.py.

References any(), and upgradeWorkflowComponents.UpgradeWorkflow.suffix.

     def condition(self, fragment, stepList, key, hasHarvest):
         # select only a subset of the workflows
         years = ['2021','2023','2024','2026']
         fragments = ["TTbar_14","ZMM_14","ZEE_14","ZTT_14","NuGun","SingleMu","QCD_Pt15To7000_Flat"]
         selected = [
             (any(y in key for y in years) and ('FS' not in key) and any( f in fragment for f in fragments)),
             (('HI' in key) and ('Hydjet' in fragment) and ("PixelOnly" in self.suffix) )
         ]
         result = any(selected) and hasHarvest
 
         return result
 

◆ setup_()

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

Definition at line 936 of file upgradeWorkflowComponents.py.

References upgradeWorkflowComponents.PatatrackWorkflow.__digi, upgradeWorkflowComponents.UpgradeWorkflow_weightedVertex.__harvest, upgradeWorkflowComponents.PatatrackWorkflow.__harvest, upgradeWorkflowComponents.PatatrackWorkflow.__mini, upgradeWorkflowComponents.UpgradeWorkflow_weightedVertex.__reco, upgradeWorkflowComponents.PatatrackWorkflow.__reco, and python.rootplot.root2matplotlib.replace().

     def setup_(self, step, stepName, stepDict, k, properties):
         # skip ALCA and Nano steps (but not RecoNano or HARVESTNano for Run3)
         if 'ALCA' in step or 'Nano'==step:
             stepDict[stepName][k] = None
         elif ('Digi' in step and "NoHLT" not in step) or 'HLTOnly' in step:
             if self.__digi is None:
               stepDict[stepName][k] = None
             else:
               stepDict[stepName][k] = merge([self.__digi, stepDict[step][k]])
         elif 'Reco' in step:
             if self.__reco is None:
               stepDict[stepName][k] = None
             else:
               stepDict[stepName][k] = merge([self.__reco, stepDict[step][k]])
             if 'Phase2' in stepDict[stepName][k]['--era']:
                 if 'DQM:@standardDQM+@ExtraHLT' in stepDict[stepName][k]['-s']:
                     stepDict[stepName][k]['-s'] = stepDict[stepName][k]['-s'].replace('DQM:@standardDQM+@ExtraHLT','DQM:@phase2')
                 if 'VALIDATION:@standardValidation' in stepDict[stepName][k]['-s']:
                     stepDict[stepName][k]['-s'] = stepDict[stepName][k]['-s'].replace('VALIDATION:@standardValidation','VALIDATION:@phase2Validation')
 
 
         elif 'MiniAOD' in step:
             if self.__mini is None:
               stepDict[stepName][k] = None
             else:
               stepDict[stepName][k] = merge([self.__mini, stepDict[step][k]])
         elif 'HARVEST' in step:
             if self.__harvest is None:
               stepDict[stepName][k] = None
             else:
               stepDict[stepName][k] = merge([self.__harvest, stepDict[step][k]])
 
 # Pixel-only quadruplets workflow running on CPU
 #  - HLT on CPU
 #  - Pixel-only reconstruction on CPU, with DQM and validation
 #  - harvesting
 
 upgradeWFs['PatatrackPixelOnlyCPU'] = PatatrackWorkflow(