Check in T0 task DB if T0 processing is done, if not raise PostponeProcessing exception.
Definition at line 303 of file BeamSpotPostProcessing.py.
◆ run()
| python.BeamSpotPostProcessing.CheckT0Status.run |
( |
| self | ) |
|
Definition at line 305 of file BeamSpotPostProcessing.py.
306 filter = 'AOD'
307 try:
308 f = self.getJobConfig(self.jobName)['inputfiles'][0]
309 if 'ESD' in f:
310 filter = 'ESD'
311 except Exception:
312 self.log('WARNING: Unable to determine input file type - will assume default (%s)\n' % filter, doPrint=True)
313 cmd = 'beamspotman.py -n -f %s queryT0 %s %s' % (filter,self.dsName,self.taskName)
314 status = self.logExec(cmd,doPrint=True,abortOnError=False)
315 if status:
316
317 if status==2:
318
319 raise PostponeProcessing('Tier-0 processing still in progress - restart postprocessing later',self.executedSteps)
320 else:
321
322 raise PostProcessingError('ERROR: Unable to determine Tier-0 task status',self.executedSteps)
323
324
◆ executedSteps
| python.BeamSpotPostProcessing.CheckT0Status.executedSteps |
The documentation for this class was generated from the following file: