10 import Alignment.OfflineValidation.TkAlAllInOneTool.configTemplates \
12 import Alignment.OfflineValidation.TkAlAllInOneTool.crabWrapper
as crabWrapper
13 from Alignment.OfflineValidation.TkAlAllInOneTool.TkAlExceptions \
15 from Alignment.OfflineValidation.TkAlAllInOneTool.helperFunctions \
16 import replaceByMap, getCommandOutput2, addIndex
17 from Alignment.OfflineValidation.TkAlAllInOneTool.betterConfigParser \
18 import BetterConfigParser
19 from Alignment.OfflineValidation.TkAlAllInOneTool.alignment
import Alignment
21 from Alignment.OfflineValidation.TkAlAllInOneTool.genericValidation \
22 import GenericValidation
23 from Alignment.OfflineValidation.TkAlAllInOneTool.geometryComparison \
24 import GeometryComparison
25 from Alignment.OfflineValidation.TkAlAllInOneTool.offlineValidation \
26 import OfflineValidation, OfflineValidationDQM
27 from Alignment.OfflineValidation.TkAlAllInOneTool.monteCarloValidation \
28 import MonteCarloValidation
29 from Alignment.OfflineValidation.TkAlAllInOneTool.trackSplittingValidation \
30 import TrackSplittingValidation
31 from Alignment.OfflineValidation.TkAlAllInOneTool.zMuMuValidation \
32 import ZMuMuValidation
33 from Alignment.OfflineValidation.TkAlAllInOneTool.preexistingValidation \
35 import Alignment.OfflineValidation.TkAlAllInOneTool.globalDictionaries \
49 def __init__( self, validation, config, options ):
50 if validation[1] ==
"":
52 valString = validation[0].
split(
"->" )[0]
53 alignments = validation[0].
split(
"->" )[1]
55 if "->" in validation[0]:
56 msg = (
"Instead of using the intermediate syntax\n'"
57 +valString.strip()+
"-> "+alignments.strip()
58 +
":'\nyou have to use the now fully supported syntax \n'"
59 +valString.strip()+
": "
60 +alignments.strip()+
"'.")
61 raise AllInOneError(msg)
63 valString = validation[0]
64 alignments = validation[1]
65 valString = valString.split()
72 print (
"offlineParallel and offline are now the same. To run an offline parallel validation,\n"
73 "just set parallelJobs to something > 1. There is no reason to call it offlineParallel anymore.")
76 if not self.__config.has_section( section ):
77 raise AllInOneError, (
"Validation '%s' of type '%s' is requested in"
78 " '[validation]' section, but is not defined."
79 "\nYou have to add a '[%s]' section."
86 if valType ==
"compare":
87 alignmentsList = alignments.split(
"," )
88 firstAlignList = alignmentsList[0].
split()
89 firstAlignName = firstAlignList[0].strip()
90 if firstAlignName ==
"IDEAL":
91 raise AllInOneError, (
"'IDEAL' has to be the second (reference)"
92 " alignment in 'compare <val_name>: "
93 "<alignment> <reference>'.")
94 if len( firstAlignList ) > 1:
95 firstRun = firstAlignList[1]
98 firstAlign = Alignment( firstAlignName, self.
__config, firstRun )
99 firstAlignName = firstAlign.name
100 secondAlignList = alignmentsList[1].
split()
101 secondAlignName = secondAlignList[0].strip()
102 if len( secondAlignList ) > 1:
103 secondRun = secondAlignList[1]
106 if secondAlignName ==
"IDEAL":
107 secondAlign = secondAlignName
109 secondAlign = Alignment( secondAlignName, self.
__config,
111 secondAlignName = secondAlign.name
114 randomWorkdirPart = \
115 globalDictionaries.alignRandDict[firstAlignName]
117 randomWorkdirPart =
None
119 validation = GeometryComparison( name, firstAlign, secondAlign,
121 self.__commandLineOptions.getImages,
123 globalDictionaries.alignRandDict[firstAlignName] = \
124 validation.randomWorkdirPart
125 if not secondAlignName ==
"IDEAL":
126 globalDictionaries.alignRandDict[secondAlignName] = \
127 validation.randomWorkdirPart
128 elif valType ==
"offline":
129 validation = OfflineValidation( name,
131 elif valType ==
"preexistingoffline":
132 validation = PreexistingOfflineValidation(name, self.
__config)
133 elif valType ==
"offlineDQM":
134 validation = OfflineValidationDQM( name,
136 elif valType ==
"mcValidate":
137 validation = MonteCarloValidation( name,
139 elif valType ==
"preexistingmcValidate":
140 validation = PreexistingMonteCarloValidation(name, self.
__config)
141 elif valType ==
"split":
142 validation = TrackSplittingValidation( name,
144 elif valType ==
"preexistingsplit":
145 validation = PreexistingTrackSplittingValidation(name, self.
__config)
146 elif valType ==
"zmumu":
147 validation = ZMuMuValidation( name,
150 raise AllInOneError,
"Unknown validation mode '%s'"%valType
155 """This private method creates the needed files for the validation job.
157 self.validation.createConfiguration( outpath )
158 self.
__scripts = sum([
addIndex(script, self.validation.NJobs)
for script
in self.validation.createScript( outpath )], [])
159 if jobMode.split(
',' )[0] ==
"crab":
160 self.validation.createCrabCfg( outpath )
164 """This is the method called to create the job files."""
168 os.path.abspath( self.__commandLineOptions.Name) )
172 log =
"> " + self.validation.name +
" is already validated."
176 general = self.__config.getGeneral()
179 name = os.path.splitext( os.path.basename( script) )[0]
180 ValidationJob.jobCount += 1
181 if self.__commandLineOptions.dryRun:
182 print "%s would run: %s"%( name, os.path.basename( script) )
184 log =
"> Validating "+name
185 print "> Validating "+name
186 if self.validation.jobmode ==
"interactive":
188 ValidationJob.interactCount += 1
189 elif self.validation.jobmode.split(
",")[0] ==
"lxBatch":
191 "commands": self.validation.jobmode.split(
",")[1],
192 "logDir": general[
"logdir"],
195 "bsub":
"/afs/cern.ch/cms/caf/scripts/cmsbsub"
199 "-o %(logDir)s/%(jobName)s.stdout "
200 "-e %(logDir)s/%(jobName)s.stderr "
204 ValidationJob.batchJobIds.append(bsubOut.split(
"<")[1].
split(
">")[0])
206 ValidationJob.batchCount += 1
207 elif self.validation.jobmode.split(
"," )[0] ==
"crab":
208 os.chdir( general[
"logdir"] )
209 crabName =
"crab." + os.path.basename( script )[:-3]
211 options = {
"-create":
"",
212 "-cfg": crabName +
".cfg",
215 theCrab.run( options )
216 except AllInOneError, e:
217 print "crab:", str(e).
split(
"\n")[0]
219 ValidationJob.crabCount += 1
222 raise AllInOneError, (
"Unknown 'jobmode'!\n"
223 "Please change this parameter either in "
224 "the [general] or in the ["
226 +
"] section to one of the following "
228 "\tinteractive\n\tlxBatch, -q <queue>\n"
229 "\tcrab, -q <queue>")
239 repMap = offlineValidationList[0].getRepMap()
241 theFile = open( outFilePath,
"w" )
242 theFile.write(
replaceByMap( configTemplates.mergeOfflineParJobsTemplate ,repMap ) )
246 repMap = offlineValidationList[0].getRepMap()
247 repMap[
"CMSSW_BASE" ] = os.environ[
'CMSSW_BASE']
248 repMap[
"resultPlotFile" ] = resultPlotFile
249 repMap[
"extendedInstantiation" ] =
""
251 for validation
in offlineValidationList:
252 repMap[
"extendedInstantiation" ] = validation.appendToExtendedValidation( repMap[
"extendedInstantiation" ] )
254 theFile = open( outFilePath,
"w" )
256 theFile.write(
replaceByMap( configTemplates.extendedValidationTemplate ,repMap ) )
260 repMap = trackSplittingValidationList[0].getRepMap()
261 repMap[
"CMSSW_BASE" ] = os.environ[
'CMSSW_BASE']
262 repMap[
"trackSplitPlotInstantiation" ] =
""
264 for validation
in trackSplittingValidationList:
265 repMap[
"trackSplitPlotInstantiation" ] = validation.appendToExtendedValidation( repMap[
"trackSplitPlotInstantiation" ] )
267 theFile = open( outFilePath,
"w" )
269 theFile.write(
replaceByMap( configTemplates.trackSplitPlotTemplate ,repMap ) )
273 if(len(validations) == 0):
274 raise AllInOneError(
"Cowardly refusing to merge nothing!")
276 repMap = validations[0].getRepMap()
279 "CompareAlignments":
"",
280 "RunExtendedOfflineValidation":
"",
281 "RunTrackSplitPlot":
"",
282 "CMSSW_BASE": os.environ[
"CMSSW_BASE"],
283 "SCRAM_ARCH": os.environ[
"SCRAM_ARCH"],
284 "CMSSW_RELEASE_BASE": os.environ[
"CMSSW_RELEASE_BASE"],
288 for validation
in validations:
289 for referenceName
in validation.filesToCompare:
290 validationName =
"%s.%s"%(validation.__class__.__name__, referenceName)
291 validationName = validationName.split(
".%s"%GenericValidation.defaultReferenceName )[0]
292 validationName = validationName.split(
"Preexisting")[-1]
293 if validationName
in comparisonLists:
294 comparisonLists[ validationName ].
append( validation )
296 comparisonLists[ validationName ] = [ validation ]
300 repMap[
"haddLoop"] =
"mergeRetCode=0\n"
301 repMap[
"rmUnmerged"] = (
"if [[ mergeRetCode -eq 0 ]]; then\n"
302 " echo -e \\n\"Merging succeeded, removing original files.\"\n")
303 repMap[
"copyMergeScripts"] =
""
304 repMap[
"mergeParallelFilePrefixes"] =
""
307 for validationType
in comparisonLists:
308 for validation
in comparisonLists[validationType]:
309 if isinstance(validation, PreexistingValidation)
or validation.NJobs == 1:
311 if validationType
not in anythingToMerge:
312 anythingToMerge += [validationType]
313 repMap[
"haddLoop"] +=
'\n\n\n\necho -e "\n\nMerging results from %s jobs"\n\n' % validationType
314 repMap[
"haddLoop"] = validation.appendToMerge(repMap[
"haddLoop"])
315 repMap[
"haddLoop"] +=
"tmpMergeRetCode=${?}\n"
316 repMap[
"haddLoop"] += (
"if [[ tmpMergeRetCode -eq 0 ]]; then "
318 +validation.getRepMap()[
"finalOutputFile"]
320 +validation.getRepMap()[
"finalResultFile"]
322 repMap[
"haddLoop"] += (
"if [[ ${tmpMergeRetCode} -gt ${mergeRetCode} ]]; then "
323 "mergeRetCode=${tmpMergeRetCode}; fi\n")
324 for f
in validation.getRepMap()[
"outputFiles"]:
325 longName = os.path.join(
"/store/caf/user/$USER/",
326 validation.getRepMap()[
"eosdir"], f)
327 repMap[
"rmUnmerged"] +=
" cmsRm "+longName+
"\n"
328 repMap[
"rmUnmerged"] += (
"else\n"
329 " echo -e \\n\"WARNING: Merging failed, unmerged"
330 " files won't be deleted.\\n"
331 "(Ignore this warning if merging was done earlier)\"\n"
334 if "OfflineValidation" in anythingToMerge:
335 repMap[
"mergeOfflineParJobsScriptPath"] = os.path.join(path,
"TkAlOfflineJobsMerge.C")
337 repMap[
"mergeOfflineParJobsScriptPath"] )
338 repMap[
"copyMergeScripts"] += (
"cp .oO[CMSSW_BASE]Oo./src/Alignment/OfflineValidation/scripts/merge_TrackerOfflineValidation.C .\n"
339 "rfcp %s .\n" % repMap[
"mergeOfflineParJobsScriptPath"])
344 repMap[
"DownloadData"] +=
replaceByMap( configTemplates.mergeParallelResults, repMap )
346 repMap[
"DownloadData"] =
""
349 if "OfflineValidation" in comparisonLists:
350 repMap[
"extendedValScriptPath"] = os.path.join(path,
"TkAlExtendedOfflineValidation.C")
352 repMap[
"extendedValScriptPath"],
354 repMap[
"RunExtendedOfflineValidation"] = \
355 replaceByMap(configTemplates.extendedValidationExecution, repMap)
357 if "TrackSplittingValidation" in comparisonLists:
358 repMap[
"trackSplitPlotScriptPath"] = \
359 os.path.join(path,
"TkAlTrackSplitPlot.C")
361 repMap[
"trackSplitPlotScriptPath"] )
362 repMap[
"RunTrackSplitPlot"] = \
363 replaceByMap(configTemplates.trackSplitPlotExecution, repMap)
365 repMap[
"CompareAlignments"] =
"#run comparisons"
366 for validationId
in comparisonLists:
367 compareStrings = [ val.getCompareStrings(validationId)
for val
in comparisonLists[validationId] ]
368 compareStringsPlain = [ val.getCompareStrings(validationId, plain=
True)
for val
in comparisonLists[validationId] ]
370 repMap.update({
"validationId": validationId,
371 "compareStrings":
" , ".
join(compareStrings),
372 "compareStringsPlain":
" ".
join(compareStringsPlain) })
374 repMap[
"CompareAlignments"] += \
375 replaceByMap(configTemplates.compareAlignmentsExecution, repMap)
377 filePath = os.path.join(path,
"TkAlMerge.sh")
378 theFile = open( filePath,
"w" )
379 theFile.write(
replaceByMap( configTemplates.mergeTemplate, repMap ) )
381 os.chmod(filePath,0755)
386 if config.has_section(
"alternateTemplates"):
387 for templateName
in config.options(
"alternateTemplates"):
388 if templateName ==
"AutoAlternates":
390 newTemplateName = config.get(
"alternateTemplates", templateName )
399 optParser = optparse.OptionParser()
400 optParser.description =
"""All-in-one Alignment Validation.
401 This will run various validation procedures either on batch queues or interactviely.
402 If no name is given (-N parameter) a name containing time and date is created automatically.
403 To merge the outcome of all validation procedures run TkAlMerge.sh in your validation's directory.
405 optParser.add_option(
"-n",
"--dryRun", dest=
"dryRun", action=
"store_true", default=
False,
406 help=
"create all scripts and cfg File but do not start jobs (default=False)")
407 optParser.add_option(
"--getImages", dest=
"getImages", action=
"store_true", default=
False,
408 help=
"get all Images created during the process (default= False)")
409 defaultConfig =
"TkAlConfig.ini"
410 optParser.add_option(
"-c",
"--config", dest=
"config", default = defaultConfig,
411 help=
"configuration to use (default TkAlConfig.ini) this can be a comma-seperated list of all .ini file you want to merge", metavar=
"CONFIG")
412 optParser.add_option(
"-N",
"--Name", dest=
"Name",
413 help=
"Name of this validation (default: alignmentValidation_DATE_TIME)", metavar=
"NAME")
414 optParser.add_option(
"-r",
"--restrictTo", dest=
"restrictTo",
415 help=
"restrict validations to given modes (comma seperated) (default: no restriction)", metavar=
"RESTRICTTO")
416 optParser.add_option(
"-s",
"--status", dest=
"crabStatus", action=
"store_true", default =
False,
417 help=
"get the status of the crab jobs", metavar=
"STATUS")
418 optParser.add_option(
"-d",
"--debug", dest=
"debugMode", action=
"store_true",
420 help=
"run the tool to get full traceback of errors",
422 optParser.add_option(
"-m",
"--autoMerge", dest=
"autoMerge", action=
"store_true", default =
False,
423 help=
"submit TkAlMerge.sh to run automatically when all jobs have finished (default=False)."
424 " Works only for batch jobs")
426 (options, args) = optParser.parse_args(argv)
428 if not options.restrictTo ==
None:
429 options.restrictTo = options.restrictTo.split(
",")
431 options.config = [ os.path.abspath( iniFile )
for iniFile
in \
432 options.config.split(
"," ) ]
433 config = BetterConfigParser()
434 outputIniFileSet = set( config.read( options.config ) )
435 failedIniFiles = [ iniFile
for iniFile
in options.config
if iniFile
not in outputIniFileSet ]
438 if options.config == [ os.path.abspath( defaultConfig ) ]:
439 if (
not options.crabStatus )
and \
440 (
not os.path.exists( defaultConfig ) ):
441 raise AllInOneError, (
"Default 'ini' file '%s' not found!\n"
442 "You can specify another name with the "
443 "command line option '-c'/'--config'."
446 for iniFile
in failedIniFiles:
447 if not os.path.exists( iniFile ):
448 raise AllInOneError, (
"'%s' does not exist. Please check for "
449 "typos in the filename passed to the "
450 "'-c'/'--config' option!"
453 raise AllInOneError, (
"'%s' does exist, but parsing of the "
454 "content failed!" ) % iniFile
457 if options.Name ==
None:
458 if not options.crabStatus:
459 options.Name =
"alignmentValidation_%s"%(datetime.datetime.now().strftime(
"%y%m%d_%H%M%S"))
461 existingValDirs = fnmatch.filter( os.walk(
'.' ).
next()[1],
462 "alignmentValidation_*" )
463 if len( existingValDirs ) > 0:
464 options.Name = existingValDirs[-1]
466 print "Cannot guess last working directory!"
467 print (
"Please use the parameter '-N' or '--Name' to specify "
468 "the task for which you want a status report." )
472 outPath = os.path.abspath( options.Name )
475 if options.crabStatus:
477 crabLogDirs = fnmatch.filter( os.walk(
'.').
next()[1],
"crab.*" )
478 if len( crabLogDirs ) == 0:
479 print "Found no crab tasks for job name '%s'"%( options.Name )
482 for crabLogDir
in crabLogDirs:
484 print "*" +
"=" * 78 +
"*"
485 print (
"| Status report and output retrieval for:"
486 +
" " * (77 - len(
"Status report and output retrieval for:" ) )
488 taskName = crabLogDir.replace(
"crab.",
"" )
489 print "| " + taskName +
" " * (77 - len( taskName ) ) +
"|"
490 print "*" +
"=" * 78 +
"*"
492 crabOptions = {
"-getoutput":
"",
495 theCrab.run( crabOptions )
496 except AllInOneError, e:
497 print "crab: No output retrieved for this task."
498 crabOptions = {
"-status":
"",
500 theCrab.run( crabOptions )
503 general = config.getGeneral()
504 config.set(
"internals",
"workdir",os.path.join(general[
"workdir"],options.Name) )
505 config.set(
"general",
"datadir",os.path.join(general[
"datadir"],options.Name) )
506 config.set(
"general",
"logdir",os.path.join(general[
"logdir"],options.Name) )
507 config.set(
"general",
"eosdir",os.path.join(
"AlignmentValidation", general[
"eosdir"], options.Name) )
511 if os.path.isdir( outPath ):
512 shutil.rmtree( outPath )
514 if not os.path.exists( outPath ):
515 os.makedirs( outPath )
516 elif not os.path.isdir( outPath ):
517 raise AllInOneError,
"the file %s is in the way rename the Job or move it away"%outPath
523 backupConfigFile = open( os.path.join( outPath,
"usedConfiguration.ini" ) ,
"w" )
524 config.write( backupConfigFile )
527 for validation
in config.items(
"validation"):
528 alignmentList = [validation[1]]
529 validationsToAdd = [(validation[0],alignment) \
530 for alignment
in alignmentList]
531 validations.extend(validationsToAdd)
533 for validation
in validations ]
534 map(
lambda job: job.createJob(), jobs )
535 validations = [ job.getValidation()
for job
in jobs ]
540 map(
lambda job: job.runJob(), jobs )
542 if options.autoMerge:
545 if ValidationJob.jobCount == ValidationJob.batchCount
and config.getGeneral()[
"jobmode"].
split(
",")[0] ==
"lxBatch":
546 print "> Automatically merging jobs when they have ended"
548 "commands": config.getGeneral()[
"jobmode"].
split(
",")[1],
549 "jobName":
"TkAlMerge",
550 "logDir": config.getGeneral()[
"logdir"],
551 "script":
"TkAlMerge.sh",
552 "bsub":
"/afs/cern.ch/cms/caf/scripts/cmsbsub",
553 "conditions":
'"' +
" && ".
join([
"ended(" + jobId +
")" for jobId
in ValidationJob.batchJobIds]) +
'"'
556 "-o %(logDir)s/%(jobName)s.stdout "
557 "-e %(logDir)s/%(jobName)s.stderr "
559 "%(logDir)s/%(script)s"%repMap)
561 if __name__ ==
"__main__":
563 if "-d" in sys.argv[1:]
or "--debug" in sys.argv[1:]:
568 except AllInOneError, e:
569 print "\nAll-In-One Tool:", str(e)
def createTrackSplitPlotScript
— Classes —############################
def createOfflineParJobsMergeScript
def main
— Main —############################
def createExtendedValidationScript
def alternateTemplate
### Alternate Templates ###
static std::string join(char **cmd)
def replaceByMap
— Helpers —############################
if(conf.exists("allCellsPositionCalc"))