Alignment/MillePedeAlignmentAlgorithm/scripts/mps_monitormerge.py - master - githubmirror/cmssw

Alignment/MillePedeAlignmentAlgorithm/scripts/mps_monitormerge.py

47 строк1 KB

Shahzad Malik Muzaffar

[ALCA-DB] py2/3 compatibility:drop use of __future__

22 ноя 2024, 20:15

22 ноя 2024, 20:15c26340c

#!/usr/bin/env python3

from builtins import range
import os
import subprocess
import argparse
import Alignment.MillePedeAlignmentAlgorithm.mpslib.Mpslibclass as mpslib

# setup argument parser 
parser = argparse.ArgumentParser(description='Merge millePedeMonitor-root-files from eos, that are from the same dataset.', 
                                 formatter_class=argparse.RawDescriptionHelpFormatter)
# positional argument: config file
parser.add_argument('eosDir', 
                    action='store', 
                    help = 'path of the eos directory')
# parse argument
args = parser.parse_args()
eosDir = args.eosDir

# read mps.db
lib = mpslib.jobdatabase()
lib.read_db()
for i in range(lib.nJobs):
	print(lib.JOBSP3[i])

# count how much jobs there are of each dataset
occurences = []
items      = []
for i in range(lib.nJobs):
	if lib.JOBSP3[i] not in items:
		items.append(lib.JOBSP3[i])

for i in range(len(items)):
	occurences.append(lib.JOBSP3.count(items[i]))

# copy files from eos and combine root-files of each dataset with "hadd"
counter = 0
for i in range(len(items)):
	command  = 'hadd '
	command += 'monitormerge_'+items[i]+'.root '	
	for j in range(occurences[i]):
		os.system('cp '+eosDir+'/millePedeMonitor%03d.root .' % (counter+j+1))
		command += 'millePedeMonitor%03d.root ' % (counter+j+1)	
	os.system(command)
	for j in range(occurences[i]):
		os.system('rm millePedeMonitor%03d.root' % (counter+j+1))
	counter += occurences[i]