Inheritance diagram for DTCalibrationWorker.DTCalibrationWorker:

Public Member Functions
def	__init__ (self, options)

def	add_arguments (cls, parser)

def	has_crab3_env (self)

def	run (self)

def	setup_crab_env (self)

Public Attributes
	options

Detailed Description

This class serves as a top level helper to perform all available
    workflows. Additional workflow classes should use the naming scheme
    DT${WORKFLOWNAME}Workflow and implement a classmethod function add_parser_options.

Definition at line 14 of file DTCalibrationWorker.py.

Constructor & Destructor Documentation

◆ init()

def DTCalibrationWorker.DTCalibrationWorker.__init__	(	self,
		options
	)

Definition at line 20 of file DTCalibrationWorker.py.

     def __init__(self, options):
         self.options = options
         if not self.has_crab3_env:
             self.setup_crab_env()
  

Member Function Documentation

◆ add_arguments()

def DTCalibrationWorker.DTCalibrationWorker.add_arguments	(	cls,
		parser
	)

Definition at line 54 of file DTCalibrationWorker.py.

     def add_arguments(cls, parser):
         workflow_parser = DTWorkflow.add_parser_options(parser)
         for workflow in cls.available_workflows:
             class_name = "DT" + workflow + "Workflow"
             try:
                 workflow_class = eval( class_name )
                 workflow_class.add_parser_options(workflow_parser)
             except:
                 log.error("No class with name: %s exists bot workflow exists in %s" %
                             (class_name, DTCalibrationWorker)
                          )
  

◆ has_crab3_env()

def DTCalibrationWorker.DTCalibrationWorker.has_crab3_env ( self )

Definition at line 34 of file DTCalibrationWorker.py.

     def has_crab3_env(self):
         if not "/crabclient/3" in os.environ["PATH"]:
             return False
         return True
  

◆ run()

def DTCalibrationWorker.DTCalibrationWorker.run ( self )

Definition at line 25 of file DTCalibrationWorker.py.

     def run(self):
         # get class object dependent on workflow
         class_name = "DT" + self.options.workflow + "Workflow"
         workflow_class = eval(class_name)
         workflow_class_instance = workflow_class(self.options)
         workflow_class_instance.run()
         return workflow_class_instance.local_path
  

References DTCalibrationWorker.DTCalibrationWorker.options, and validateAlignments.ValidationJobMultiIOV.options.

Referenced by DTWorkflow.DTWorkflow.all(), Types.EventID.cppID(), Types.LuminosityBlockID.cppID(), and o2olib.O2OTool.execute().

◆ setup_crab_env()

def DTCalibrationWorker.DTCalibrationWorker.setup_crab_env ( self )

Definition at line 39 of file DTCalibrationWorker.py.

     def setup_crab_env(self):
         # following
         #http://.com/questions/3503719/emulating-bash-source-in-python
         command = ['bash', '-c', 'unset module;source /cvmfs/cms.cern.ch/crab3/crab.sh && env']
         proc = subprocess.Popen(command, stdout = subprocess.PIPE)
  
         print('setting up crab')
         for line in proc.stdout:
           (key, _, value) = line.partition("=")
           os.environ[key] = value.replace("\n","")
         for path in os.environ['PYTHONPATH'].split(':'):
             sys.path.append(path)
         proc.communicate()
  

References edm.print(), and cms::dd.split().

Member Data Documentation

◆ options

DTCalibrationWorker.DTCalibrationWorker.options

Definition at line 21 of file DTCalibrationWorker.py.

Public Member Functions

Public Attributes