Inheritance diagram for python.BeamSpotPostProcessing.DQBeamSpot:

Collaboration diagram for python.BeamSpotPostProcessing.DQBeamSpot:

Public Member Functions
	run (self, absent=False)

Public Attributes
	taskDir
	executedSteps
	dsName
	taskName

Detailed Description

Automatically determine DQ info (after uploading beamspot)

Definition at line 363 of file BeamSpotPostProcessing.py.

Member Function Documentation

◆ run()

python.BeamSpotPostProcessing.DQBeamSpot.run	(		self,
			absent = False )

Reimplemented in python.BeamSpotPostProcessing.DQBeamSpotReproc.

Definition at line 365 of file BeamSpotPostProcessing.py.

    def run(self, absent=False):
        ntFileName              = self.getFileName('-nt.root','BeamSpotNt')
        dataQualityDbFileName   = self.getFileName('-dqflags.db')
 
        if os.path.exists('/'.join([self.taskDir,dataQualityDbFileName])):
            self.logExec('cd %s; rm -f %s' % (self.taskDir,dataQualityDbFileName))
 
        if os.path.exists('/'.join([self.taskDir,ntFileName])):
            cmd = 'cd %s; dqBeamSpot.py -b %s -o %s %s' % (self.taskDir,'-a' if absent else '',dataQualityDbFileName,ntFileName)
            status = self.logExec(cmd,doPrint=True,abortOnError=False)
 
            if status:
                raise PostProcessingError('ERROR in postprocessing step DQBeamSpot while executing:\n\n%s\n' % (cmd),self.executedSteps)
 
            # Add DQ flags to results and do linking
            self.addResult(dataQualityDbFileName)
            
            dataQualityTxtFileName = dataQualityDbFileName.replace('.db','.txt')            
            cmd = 'grep -c "ID_BS_NOBEAMSPOT" %s/%s' %  (self.taskDir, dataQualityTxtFileName)
            status,out = subprocess.getstatusoutput(cmd)
 
            # Catch errors (do it this way as the exit codes from grep are nasty)
            try:
                nRed=int(out)                                                
            except ValueError:
                raise PostProcessingError('ERROR in postprocessing step DQBeamSpot while executing:\n\n%s\n' % (cmd),self.executedSteps)
        
            if nRed==0:
                link='<a class="ok" href="../files?u=%s/%s/%s-dqflags.txt">DQFlags</a>' % (self.dsName,self.taskName,self.baseNameStep)
            else:
                link='<a class="bad" href="../files?u=%s/%s/%s-dqflags.txt">DQFlags</a>' % (self.dsName,self.taskName,self.baseNameStep)                
 
            resultLinks = self.taskDict['RESULTLINKS']
            if resultLinks.find(link)==-1:
                resultLinks = ' '.join([resultLinks, link])
 
            # Set links by hand
            self.taskman.setValue(self.dsName,self.taskName,'RESULTLINKS',resultLinks)
        else:
            raise PostProcessingError('ERROR: No ntuple file %s - did BeamSpotNt step run?\n' % ntFileName,self.executedSteps)
 

Member Data Documentation

◆ dsName

python.BeamSpotPostProcessing.DQBeamSpot.dsName

Definition at line 402 of file BeamSpotPostProcessing.py.

◆ executedSteps

python.BeamSpotPostProcessing.DQBeamSpot.executedSteps

Definition at line 377 of file BeamSpotPostProcessing.py.

◆ taskDir

python.BeamSpotPostProcessing.DQBeamSpot.taskDir

Definition at line 369 of file BeamSpotPostProcessing.py.

◆ taskName

python.BeamSpotPostProcessing.DQBeamSpot.taskName