upgradeWorkflowComponents.UpgradeWorkflowTracking Class Reference

Inheritance diagram for upgradeWorkflowComponents.UpgradeWorkflowTracking:

Public Member Functions
def	__init__ (self, steps, PU, suffix, offset)
def	condition (self, fragment, stepList, key, hasHarvest)
def	condition_ (self, fragment, stepList, key, hasHarvest)
def	setup_ (self, step, stepName, stepDict, k, properties)
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)

Additional Inherited Members
Public Attributes inherited from upgradeWorkflowComponents.UpgradeWorkflow
	allowReuse
	offset
	PU
	steps
	suffix

Detailed Description

Definition at line 279 of file upgradeWorkflowComponents.py.

Constructor & Destructor Documentation

__init__()

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

Definition at line 281 of file upgradeWorkflowComponents.py.

    def __init__(self, steps, PU, suffix, offset):
        # always include some steps that will be skipped
        steps = steps + ["ALCA","Nano"]
        super().__init__(steps, PU, suffix, offset)

Member Function Documentation

condition()

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

Definition at line 285 of file upgradeWorkflowComponents.py.

References edm::waiting_task::detail::ConditionalAdaptor< F >.condition_, edm::waiting_task::detail::WaitingTaskChain< Conditional< U >, T... >.condition_, timestudy::SleepingServer.condition_, and upgradeWorkflowComponents.UpgradeWorkflowTracking.condition_().

    def condition(self, fragment, stepList, key, hasHarvest):
        result = (fragment=="TTbar_13" or fragment=="TTbar_14TeV" or 'Hydjet' in fragment) and not 'PU' in key and hasHarvest and self.condition_(fragment, stepList, key, hasHarvest)
        return result

condition_()

def upgradeWorkflowComponents.UpgradeWorkflowTracking.condition_	(		self,
			fragment,
			stepList,
			key,
			hasHarvest
	)

Definition at line 288 of file upgradeWorkflowComponents.py.

Referenced by upgradeWorkflowComponents.UpgradeWorkflowTracking.condition(), and upgradeWorkflowComponents.UpgradeWorkflow_trackingOnly.condition().

    def condition_(self, fragment, stepList, key, hasHarvest):
        return True

setup_()

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

Definition at line 290 of file upgradeWorkflowComponents.py.

References upgradeWorkflowComponents.UpgradeWorkflowTracking.setup__().

    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
        self.setup__(step, stepName, stepDict, k, properties)

setup__()

def upgradeWorkflowComponents.UpgradeWorkflowTracking.setup__	(		self,
			step,
			stepName,
			stepDict,
			k,
			properties
	)

Definition at line 296 of file upgradeWorkflowComponents.py.

Referenced by upgradeWorkflowComponents.UpgradeWorkflowTracking.setup_().

    def setup__(self, step, stepName, stepDict, k, properties):
        pass