192 '''Setup the cascade of merge jobs and execute each level in turn'''
196 jobGraph.append(haddStep(bunchNumber = args[
'bunchNumber'],
197 inputFiles = args[
'inputFiles'],
198 finalOutputFile = args[
'outputFile'], level = level))
200 while jobGraph[-1].numHadds > 1:
202 jobGraph.append(haddStep(bunchNumber = args[
'bunchNumber'],
203 inputFiles = jobGraph[-1].outputFiles,
204 finalOutputFile = args[
'outputFile'], level = level))
205 logging.debug(jobGraph[-1])
208 for i, jobs
in enumerate(jobGraph):
209 logging.info(
'Executing merge interation step %d' % i)
210 jobs.executeAll(args[
'parallelMerge'])
212 logging.info(
'Final merge completed successfully.')