Inheritance diagram for upgradeWorkflowComponents.PatatrackWorkflow:

Public Member Functions
def	__init__ (self, digi={}, reco={}, 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

	__reco

Additional Inherited Members
Public Attributes inherited from upgradeWorkflowComponents.UpgradeWorkflow
	allowReuse

	offset

	PU

	steps

	suffix

Detailed Description

Definition at line 616 of file upgradeWorkflowComponents.py.

Constructor & Destructor Documentation

◆ init()

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

Definition at line 617 of file upgradeWorkflowComponents.py.

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

Member Function Documentation

◆ condition()

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

Definition at line 645 of file upgradeWorkflowComponents.py.

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

     def condition(self, fragment, stepList, key, hasHarvest):
         # select only a subset of the workflows
         selected = [
             ('2018' in key and fragment == "TTbar_13"),
             ('2021' in key and fragment == "TTbar_14TeV" and 'FS' not in key),
             ('2018' in key and fragment == "ZMM_13"),
             ('2021' in key and fragment == "ZMM_14" and 'FS' not in key),
             ('2026D88' in key and fragment == "TTbar_14TeV" 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 658 of file upgradeWorkflowComponents.py.

References upgradeWorkflowComponents.PatatrackWorkflow.__digi, upgradeWorkflowComponents.PatatrackWorkflow.__harvest, and upgradeWorkflowComponents.PatatrackWorkflow.__reco.

     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:
             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]])
         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(