Inheritance diagram for validateAlignments.ValidationJob:

Public Member Functions
def	__init__ (self, validation, config, options, args, kwargs)

def	__iter__ (self)

def	__next__ (self)

def	createJob (self)

def	getValidation (self)

def	needsproxy (self)

def	runJob (self)

Public Member Functions inherited from validateAlignments.ValidationBase
def	__init__ (self, validation, config, options)

def	createJob (self)

def	getValidation (self)

def	needsproxy (self)

def	runJob (self)

Public Attributes
	end

	JobId

	scripts

	start

	validation

Public Attributes inherited from validateAlignments.ValidationBase
	alignments

	commandLineOptions

	config

	preexisting

	valName

	valSection

	valType

Static Public Attributes
	condorConf

	interactCount

	jobCount

Private Member Functions
def	__createJob (self, jobMode, outpath)

def	__getValidation (self, valType, name, alignments, config, options)

Detailed Description

Definition at line 116 of file validateAlignments.py.

Constructor & Destructor Documentation

def validateAlignments.ValidationJob.__init__	(	self,
		validation,
		config,
		options,
		args,
		kwargs
	)

Definition at line 123 of file validateAlignments.py.

     def __init__( self, validation, config, options, *args, **kwargs ):
 
         self.start = 0
         self.end = args
         self.JobId=[]
         super(ValidationJob, self).__init__( validation, config, options )
         self.validation = self.__getValidation( self.valType, self.valName,
                                                   self.alignments, config,
                                                   options )
 

Member Function Documentation

def validateAlignments.ValidationJob.__createJob	(	self,
		jobMode,
		outpath
	)

private

This private method creates the needed files for the validation job.

Definition at line 202 of file validateAlignments.py.

References validateAlignments.ValidationBase.preexisting.

Referenced by validateAlignments.ValidationJob.createJob().

     def __createJob( self, jobMode, outpath ):
         """This private method creates the needed files for the validation job.
            """
         self.validation.createConfiguration( outpath )
         if self.preexisting:
             return
         self.scripts = sum([addIndex(script, self.validation.NJobs) for script in self.validation.createScript( outpath )], [])
         return None
 

def validateAlignments.ValidationJob.__getValidation	(	self,
		valType,
		name,
		alignments,
		config,
		options
	)

private

Definition at line 133 of file validateAlignments.py.

References split, and digitizers_cfi.strip.

     def __getValidation( self, valType, name, alignments, config, options ):
         if valType == "compare":
             alignmentsList = alignments.split( "," )
             firstAlignList = alignmentsList[0].split()
             firstAlignName = firstAlignList[0].strip()
             if firstAlignName == "IDEAL":
                 raise AllInOneError("'IDEAL' has to be the second (reference)"
                                       " alignment in 'compare <val_name>: "
                                       "<alignment> <reference>'.")
             if len( firstAlignList ) > 1:
                 firstRun = firstAlignList[1]
             elif config.has_section("IOV"):
                 firstRun = config.get("IOV", "iov")
             else:
                 raise AllInOneError("Have to provide a run number for geometry comparison")
             firstAlign = Alignment( firstAlignName, config, firstRun )
             firstAlignName = firstAlign.name
             secondAlignList = alignmentsList[1].split()
             secondAlignName = secondAlignList[0].strip()
             if secondAlignName == "IDEAL":
                 secondAlign = secondAlignName
             else:
                 if len( secondAlignList ) > 1:
                     secondRun = secondAlignList[1]
                 elif config.has_section("IOV"):
                     secondRun = config.get("IOV", "iov")
                 else:
                     raise AllInOneError("Have to provide a run number for geometry comparison")
                 secondAlign = Alignment( secondAlignName, config,
                                          secondRun )
                 secondAlignName = secondAlign.name
 
             validation = GeometryComparison( name, firstAlign, secondAlign,
                                              config,
                                              self.commandLineOptions.getImages)
         elif valType == "offline":
             validation = OfflineValidation( name,
                 Alignment( alignments.strip(), config ), config )
         elif valType == "preexistingoffline":
             validation = PreexistingOfflineValidation(name, config)
         elif valType == "offlineDQM":
             validation = OfflineValidationDQM( name,
                 Alignment( alignments.strip(), config ), config )
         elif valType == "mcValidate":
             validation = MonteCarloValidation( name,
                 Alignment( alignments.strip(), config ), config )
         elif valType == "preexistingmcValidate":
             validation = PreexistingMonteCarloValidation(name, config)
         elif valType == "split":
             validation = TrackSplittingValidation( name,
                 Alignment( alignments.strip(), config ), config )
         elif valType == "preexistingsplit":
             validation = PreexistingTrackSplittingValidation(name, config)
         elif valType == "zmumu":
             validation = ZMuMuValidation( name,
                 Alignment( alignments.strip(), config ), config )
         elif valType == "primaryvertex":
             validation = PrimaryVertexValidation( name,
                 Alignment( alignments.strip(), config ), config )
         elif valType == "preexistingprimaryvertex":
             validation = PreexistingPrimaryVertexValidation(name, self.__config)
         elif valType == "overlap":
             validation = OverlapValidation( name,
                 Alignment( alignments.strip(), self.__config ), self.__config )
         else:
             raise AllInOneError("Unknown validation mode '%s'"%valType)
 
         return validation
 

def validateAlignments.ValidationJob.__iter__ ( self )

Definition at line 277 of file validateAlignments.py.

     def __iter__(self):
         yield self
 

def validateAlignments.ValidationJob.__next__ ( self )

Definition at line 280 of file validateAlignments.py.

References validateAlignments.ValidationJob.end, svgfig.LineAxis.end, validateAlignments.ValidationJob.start, and svgfig.LineAxis.start.

     def __next__(self):
         if self.start >= len(self.end):
             raise StopIteration
         else:
             self.start += 1
             return self.end[self.start-1]
 
 

def validateAlignments.ValidationJob.createJob ( self )

This is the method called to create the job files.

Definition at line 211 of file validateAlignments.py.

References validateAlignments.ValidationJob.__createJob().

     def createJob(self):
         """This is the method called to create the job files."""
         self.__createJob( self.validation.jobmode,
                           os.path.abspath( self.commandLineOptions.Name) )
 

def validateAlignments.ValidationJob.getValidation ( self )

Definition at line 271 of file validateAlignments.py.

References validateAlignments.ValidationJob.validation.

     def getValidation( self ):
         return self.validation
 

def validateAlignments.ValidationJob.needsproxy ( self )

Definition at line 274 of file validateAlignments.py.

References validateAlignments.ValidationBase.preexisting.

     def needsproxy(self):
         return self.validation.needsproxy and not self.preexisting and not self.commandLineOptions.dryRun
 

def validateAlignments.ValidationJob.runJob ( self )

Definition at line 216 of file validateAlignments.py.

References mps_setup.append, helperFunctions.getCommandOutput2(), validateAlignments.ValidationBase.preexisting, edm.print(), validateAlignments.ValidationJob.scripts, validateAlignments.ValidationBase.valName, monteCarloValidation.MonteCarloValidation.valType, trackSplittingValidation.TrackSplittingValidation.valType, overlapValidation.OverlapValidation.valType, primaryVertexValidation.PrimaryVertexValidation.valType, offlineValidation.OfflineValidation.valType, zMuMuValidation.ZMuMuValidation.valType, geometryComparison.GeometryComparison.valType, and validateAlignments.ValidationBase.valType.

     def runJob( self ):
         general = self.config.getGeneral()
         log = ""
 
         if self.preexisting:
             if self.validation.config.has_section("IOV"):
                 iov = self.validation.config.get("IOV", "iov")
             else:
                 iov = "singleIOV"
             preexistingValType = self.valType
             originalValType = preexistingValType.replace('preexisting', '')
             key = (originalValType, self.validation.originalValName, iov)
             if key in ValidationJob.condorConf:
                 ValidationJob.condorConf[key].append(("preexisting", "", general["logdir"]))
             else:
                 ValidationJob.condorConf[key] = [("preexisting", "", general["logdir"])]
             log = ">             " + self.validation.name + " is already validated."
             return log
 
         for script in self.scripts:
             name = os.path.splitext( os.path.basename( script) )[0]
             ValidationJob.jobCount += 1
             if self.commandLineOptions.dryRun:
                 print("%s would run: %s"%( name, os.path.basename( script) ))
                 continue
             log = ">             Validating "+name
             print(">             Validating "+name)
             if self.validation.jobmode == "interactive":
                 log += getCommandOutput2( script )
                 ValidationJob.interactCount += 1
             elif self.validation.jobmode.split( "," )[0] == "condor":
                 if self.validation.config.has_section("IOV"):
                     iov = self.validation.config.get("IOV", "iov")
                 else:
                     iov = "singleIOV"
                 scriptPaths = script.split("/")
                 scriptName = scriptPaths[-1]
                 scriptName = scriptName.split(".")
                 jobName = "%s"%scriptName[0] + "_%s"%scriptName[1]+"_%s"%scriptName[2]
                 key = (self.valType, self.valName, iov)
                 if key in ValidationJob.condorConf:
                     ValidationJob.condorConf[key].append((jobName, script, general["logdir"]))
                 else:
                     ValidationJob.condorConf[key] = [(jobName, script, general["logdir"])]
             else:
                 raise AllInOneError("Unknown 'jobmode'!\n"
                                       "Please change this parameter either in "
                                       "the [general] or in the ["
                                       + self.valType + ":" + self.valName
                                       + "] section to one of the following "
                                       "values:\n"
                                       "\tinteractive\n\tcondor, -q <queue>\n")
 
         return log
 