Inheritance diagram for python.BeamSpotPostProcessing.UploadBeamSpot:

Collaboration diagram for python.BeamSpotPostProcessing.UploadBeamSpot:

Public Member Functions
	run (self)

Public Attributes
	executedSteps
	taskDir
	dsName
	taskName

Detailed Description

Definition at line 325 of file BeamSpotPostProcessing.py.

Member Function Documentation

◆ run()

python.BeamSpotPostProcessing.UploadBeamSpot.run ( self )

Definition at line 326 of file BeamSpotPostProcessing.py.

    def run(self):
        beamSpotDbFileName = self.getFileName('-beamspot.db','AveBeamSpot')
        cooltags = self.taskDict['COOLTAGS']
        if not cooltags: cooltags = ''
 
        # Resolve beamspot tag
        try: 
            beamspottag = COOLUtils.resolveCurrentBeamSpotFolder()
        except Exception:
            raise PostProcessingError('ERROR: Unable to resolve beamspot folder tag',self.executedSteps,TaskManager.StatusCodes['POSTPROCFAILED'])
        
        # Check that we haven't uploaded yet
        if beamspottag in cooltags.split():
            self.log('WARNING: Beam spot already uploaded to COOL:  %s - continue anyway' % beamspottag)
            # This command is kept for possible future use: raise PostProcessingError('ERROR: Beam spot already uploaded to COOL - if this is intentional, please upload manually.',
            # self.executedSteps,TaskManager.StatusCodes['POSTPROCFAILED'])
            
        # Check that this is the express stream
        if self.dsName.split('.')[-1] != 'express_express' and self.dsName.split('.')[-1] != 'calibration_BeamSpot':
            print (self.dsName.split('.')[-1] )
            self.log(text="WARNING: Not running on the express or BeamSpot  stream, so won't upload anything - if this is intentional, please upload manually\n",doPrint=True)
            return
        if os.path.exists('/'.join([self.taskDir,beamSpotDbFileName])):
            # Dumping of the beam spot SQLite file is done by beamspotman
            #self.logExec('cd %s; dumpBeamSpot.py %s' % (self.taskDir,beamSpotDbFileName))
            self.logExec('beamspotman.py -b -n -t %s upload %s %s' % (beamspottag,self.dsName,self.taskName))
        else:
            #raise PostProcessingError('ERROR: No beam spot COOL SQLite file %s - did AveBeamSpot succeed?\n' % beamSpotDbFileName,self.executedSteps)
            self.log(text='ERROR: No beam spot COOL SQLite file %s\n       Nothing to upload - was beam spot determination successful?\n' % beamSpotDbFileName,doPrint=True)
 
#         # Once uploaded the beamspot can upload the DQ flags 
#         dataQualityDbFileName = self.getFileName('-dqflags.db','AveBeamSpot')
#         if os.path.exists('/'.join([self.taskDir,dataQualityDbFileName])):
#             self.logExec('beamspotman.py -b -n --dqtag %s dqflag %s %s' % (dqtag,self.dsName,self.taskName))
#         else:
#             self.log(text='ERROR: No beam spot DQ flag SQLite file %s\n       Nothing to upload - was beam spot or DQ determination successful?\n' % dqDbFileName,doPrint=True)
 

Member Data Documentation

◆ dsName

python.BeamSpotPostProcessing.UploadBeamSpot.dsName

Definition at line 351 of file BeamSpotPostProcessing.py.

◆ executedSteps

python.BeamSpotPostProcessing.UploadBeamSpot.executedSteps

Definition at line 335 of file BeamSpotPostProcessing.py.

◆ taskDir

python.BeamSpotPostProcessing.UploadBeamSpot.taskDir

Definition at line 348 of file BeamSpotPostProcessing.py.

◆ taskName

python.BeamSpotPostProcessing.UploadBeamSpot.taskName