196 ntFileName = self.getFileName('-nt.root')
197 if os.path.exists('/'.join([self.taskDir,ntFileName])):
198 self.logExec('cd %s; rm -f %s' % (self.taskDir,ntFileName))
199 postProcFiles = self.taskFileList('*-nt.root','POSTPROCESSING',self.jobName)
200 self.log(text='Found %i ntuple files from POSTPROCESSING jobs ...' % len(postProcFiles))
201 completedFiles = self.taskFileList('*-nt.root','COMPLETED',self.jobName)
202 self.log(text='Found %i ntuple files from COMPLETED jobs ...' % len(completedFiles))
203 ntFiles = sorted(postProcFiles+completedFiles)
204 if len(ntFiles)>0:
205
206 self.hadd(self.taskDir,ntFileName,ntFiles)
207 self.addResult(ntFileName)
208 else:
209 raise PostProcessingError('WARNING: No beam spot ntuple files to merge',self.executedSteps)
210
211