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 15 of file DTCalibrationWorker.py.

Constructor & Destructor Documentation

◆ init()

def DTCalibrationWorker.DTCalibrationWorker.__init__	(	self,
		options
	)

Definition at line 21 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 55 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 but workflow exists in %s" %
                             (class_name, DTCalibrationWorker)
                          )
 
 

◆ has_crab3_env()

def DTCalibrationWorker.DTCalibrationWorker.has_crab3_env ( self )

Definition at line 35 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 26 of file DTCalibrationWorker.py.

References DTCalibrationWorker.DTCalibrationWorker.options.

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

     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
 

◆ setup_crab_env()

def DTCalibrationWorker.DTCalibrationWorker.setup_crab_env ( self )

Definition at line 40 of file DTCalibrationWorker.py.

References print(), python.rootplot.root2matplotlib.replace(), and submitPVValidationJobs.split().

     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, executable = '/bin/bash', stdout = subprocess.PIPE)
 
         print('setting up crab')
         for line in proc.stdout:
           (key, _, value) = line.partition(b"=")
           os.environ[key.decode()] = value.decode().replace("\n","")
         for path in os.environ['PYTHONPATH'].split(':'):
             sys.path.append(path)
         proc.communicate()
 

Member Data Documentation

◆ options

DTCalibrationWorker.DTCalibrationWorker.options

Definition at line 22 of file DTCalibrationWorker.py.

Public Member Functions

Public Attributes