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()
77 print (
"offlineParallel and offline are now the same. To run an offline parallel validation,\n"
78 "just set parallelJobs to something > 1. There is no reason to call it offlineParallel anymore.")
81 if not self.__config.has_section( section ):
82 raise AllInOneError, (
"Validation '%s' of type '%s' is requested in"
83 " '[validation]' section, but is not defined."
84 "\nYou have to add a '[%s]' section."
91 if valType ==
"compare":
92 alignmentsList = alignments.split(
"," )
93 firstAlignList = alignmentsList[0].
split()
94 firstAlignName = firstAlignList[0].strip()
95 if firstAlignName ==
"IDEAL":
96 raise AllInOneError, (
"'IDEAL' has to be the second (reference)"
97 " alignment in 'compare <val_name>: "
98 "<alignment> <reference>'.")
99 if len( firstAlignList ) > 1:
100 firstRun = firstAlignList[1]
104 firstAlignName = firstAlign.name
105 secondAlignList = alignmentsList[1].
split()
106 secondAlignName = secondAlignList[0].strip()
107 if len( secondAlignList ) > 1:
108 secondRun = secondAlignList[1]
111 if secondAlignName ==
"IDEAL":
112 secondAlign = secondAlignName
116 secondAlignName = secondAlign.name
118 validation = GeometryComparison( name, firstAlign, secondAlign,
120 self.__commandLineOptions.getImages)
121 elif valType ==
"offline":
122 validation = OfflineValidation( name,
124 elif valType ==
"preexistingoffline":
125 validation = PreexistingOfflineValidation(name, self.
__config)
126 elif valType ==
"offlineDQM":
127 validation = OfflineValidationDQM( name,
129 elif valType ==
"mcValidate":
130 validation = MonteCarloValidation( name,
132 elif valType ==
"preexistingmcValidate":
133 validation = PreexistingMonteCarloValidation(name, self.
__config)
134 elif valType ==
"split":
135 validation = TrackSplittingValidation( name,
137 elif valType ==
"preexistingsplit":
138 validation = PreexistingTrackSplittingValidation(name, self.
__config)
139 elif valType ==
"zmumu":
140 validation = ZMuMuValidation( name,
143 raise AllInOneError,
"Unknown validation mode '%s'"%valType
147 """This private method creates the needed files for the validation job.
149 self.validation.createConfiguration( outpath )
152 self.
__scripts = sum([
addIndex(script, self.validation.NJobs)
for script
in self.validation.createScript( outpath )], [])
153 if jobMode.split(
',' )[0] ==
"crab":
154 self.validation.createCrabCfg( outpath )
158 """This is the method called to create the job files."""
160 os.path.abspath( self.__commandLineOptions.Name) )
164 log =
"> " + self.validation.name +
" is already validated."
168 general = self.__config.getGeneral()
171 name = os.path.splitext( os.path.basename( script) )[0]
172 ValidationJob.jobCount += 1
173 if self.__commandLineOptions.dryRun:
174 print "%s would run: %s"%( name, os.path.basename( script) )
176 log =
"> Validating "+name
177 print "> Validating "+name
178 if self.validation.jobmode ==
"interactive":
180 ValidationJob.interactCount += 1
181 elif self.validation.jobmode.split(
",")[0] ==
"lxBatch":
183 "commands": self.validation.jobmode.split(
",")[1],
184 "logDir": general[
"logdir"],
187 "bsub":
"/afs/cern.ch/cms/caf/scripts/cmsbsub"
189 for ext
in (
"stdout",
"stderr",
"stdout.gz",
"stderr.gz"):
190 oldlog =
"%(logDir)s/%(jobName)s."%repMap + ext
191 if os.path.exists(oldlog):
195 "-o %(logDir)s/%(jobName)s.stdout "
196 "-e %(logDir)s/%(jobName)s.stderr "
200 ValidationJob.batchJobIds.append(bsubOut.split(
"<")[1].
split(
">")[0])
202 ValidationJob.batchCount += 1
203 elif self.validation.jobmode.split(
"," )[0] ==
"crab":
204 os.chdir( general[
"logdir"] )
205 crabName =
"crab." + os.path.basename( script )[:-3]
207 options = {
"-create":
"",
208 "-cfg": crabName +
".cfg",
211 theCrab.run( options )
212 except AllInOneError, e:
213 print "crab:", str(e).
split(
"\n")[0]
215 ValidationJob.crabCount += 1
218 raise AllInOneError, (
"Unknown 'jobmode'!\n"
219 "Please change this parameter either in "
220 "the [general] or in the ["
222 +
"] section to one of the following "
224 "\tinteractive\n\tlxBatch, -q <queue>\n"
225 "\tcrab, -q <queue>")
235 repMap = offlineValidationList[0].getRepMap()
237 theFile = open( outFilePath,
"w" )
238 theFile.write(
replaceByMap( configTemplates.mergeOfflineParJobsTemplate ,repMap ) )
242 repMap = offlineValidationList[0].getRepMap()
243 repMap[
"CMSSW_BASE" ] = os.environ[
'CMSSW_BASE']
244 repMap[
"resultPlotFile" ] = resultPlotFile
245 repMap[
"extendedInstantiation" ] =
""
247 for validation
in offlineValidationList:
248 repMap[
"extendedInstantiation" ] = validation.appendToExtendedValidation( repMap[
"extendedInstantiation" ] )
250 theFile = open( outFilePath,
"w" )
252 theFile.write(
replaceByMap( configTemplates.extendedValidationTemplate ,repMap ) )
256 repMap = trackSplittingValidationList[0].getRepMap()
257 repMap[
"CMSSW_BASE" ] = os.environ[
'CMSSW_BASE']
258 repMap[
"trackSplitPlotInstantiation" ] =
""
260 for validation
in trackSplittingValidationList:
261 repMap[
"trackSplitPlotInstantiation" ] = validation.appendToExtendedValidation( repMap[
"trackSplitPlotInstantiation" ] )
263 theFile = open( outFilePath,
"w" )
265 theFile.write(
replaceByMap( configTemplates.trackSplitPlotTemplate ,repMap ) )
269 if(len(validations) == 0):
270 raise AllInOneError(
"Cowardly refusing to merge nothing!")
272 repMap = validations[0].getRepMap()
275 "CompareAlignments":
"",
276 "RunExtendedOfflineValidation":
"",
277 "RunTrackSplitPlot":
"",
278 "CMSSW_BASE": os.environ[
"CMSSW_BASE"],
279 "SCRAM_ARCH": os.environ[
"SCRAM_ARCH"],
280 "CMSSW_RELEASE_BASE": os.environ[
"CMSSW_RELEASE_BASE"],
284 for validation
in validations:
285 for referenceName
in validation.filesToCompare:
286 validationName =
"%s.%s"%(validation.__class__.__name__, referenceName)
287 validationName = validationName.split(
".%s"%GenericValidation.defaultReferenceName )[0]
288 validationName = validationName.split(
"Preexisting")[-1]
289 if validationName
in comparisonLists:
290 comparisonLists[ validationName ].
append( validation )
292 comparisonLists[ validationName ] = [ validation ]
296 repMap[
"haddLoop"] =
"mergeRetCode=0\n"
297 repMap[
"rmUnmerged"] = (
"if [[ mergeRetCode -eq 0 ]]; then\n"
298 " echo -e \\n\"Merging succeeded, removing original files.\"\n")
299 repMap[
"copyMergeScripts"] =
""
300 repMap[
"mergeParallelFilePrefixes"] =
""
303 for validationType
in comparisonLists:
304 for validation
in comparisonLists[validationType]:
305 if isinstance(validation, PreexistingValidation)
or validation.NJobs == 1:
307 if validationType
not in anythingToMerge:
308 anythingToMerge += [validationType]
309 repMap[
"haddLoop"] +=
'\n\n\n\necho -e "\n\nMerging results from %s jobs"\n\n' % validationType
310 repMap[
"haddLoop"] = validation.appendToMerge(repMap[
"haddLoop"])
311 repMap[
"haddLoop"] +=
"tmpMergeRetCode=${?}\n"
312 repMap[
"haddLoop"] += (
"if [[ tmpMergeRetCode -eq 0 ]]; then "
314 +validation.getRepMap()[
"finalOutputFile"]
315 +
" root://eoscms//eos/cms"
316 +validation.getRepMap()[
"finalResultFile"]
318 repMap[
"haddLoop"] += (
"if [[ ${tmpMergeRetCode} -gt ${mergeRetCode} ]]; then "
319 "mergeRetCode=${tmpMergeRetCode}; fi\n")
320 for f
in validation.getRepMap()[
"outputFiles"]:
321 longName = os.path.join(
"/store/caf/user/$USER/",
322 validation.getRepMap()[
"eosdir"], f)
323 repMap[
"rmUnmerged"] +=
" $eos rm "+longName+
"\n"
324 repMap[
"rmUnmerged"] += (
"else\n"
325 " echo -e \\n\"WARNING: Merging failed, unmerged"
326 " files won't be deleted.\\n"
327 "(Ignore this warning if merging was done earlier)\"\n"
330 if "OfflineValidation" in anythingToMerge:
331 repMap[
"mergeOfflineParJobsScriptPath"] = os.path.join(path,
"TkAlOfflineJobsMerge.C")
333 repMap[
"mergeOfflineParJobsScriptPath"] )
334 repMap[
"copyMergeScripts"] += (
"cp .oO[CMSSW_BASE]Oo./src/Alignment/OfflineValidation/scripts/merge_TrackerOfflineValidation.C .\n"
335 "rfcp %s .\n" % repMap[
"mergeOfflineParJobsScriptPath"])
340 repMap[
"DownloadData"] +=
replaceByMap( configTemplates.mergeParallelResults, repMap )
342 repMap[
"DownloadData"] =
""
345 if "OfflineValidation" in comparisonLists:
346 repMap[
"extendedValScriptPath"] = os.path.join(path,
"TkAlExtendedOfflineValidation.C")
348 repMap[
"extendedValScriptPath"],
350 repMap[
"RunExtendedOfflineValidation"] = \
351 replaceByMap(configTemplates.extendedValidationExecution, repMap)
353 if "TrackSplittingValidation" in comparisonLists:
354 repMap[
"trackSplitPlotScriptPath"] = \
355 os.path.join(path,
"TkAlTrackSplitPlot.C")
357 repMap[
"trackSplitPlotScriptPath"] )
358 repMap[
"RunTrackSplitPlot"] = \
359 replaceByMap(configTemplates.trackSplitPlotExecution, repMap)
361 repMap[
"CompareAlignments"] =
"#run comparisons"
362 for validationId
in comparisonLists:
363 compareStrings = [ val.getCompareStrings(validationId)
for val
in comparisonLists[validationId] ]
364 compareStringsPlain = [ val.getCompareStrings(validationId, plain=
True)
for val
in comparisonLists[validationId] ]
366 repMap.update({
"validationId": validationId,
367 "compareStrings":
" , ".
join(compareStrings),
368 "compareStringsPlain":
" ".
join(compareStringsPlain) })
370 repMap[
"CompareAlignments"] += \
371 replaceByMap(configTemplates.compareAlignmentsExecution, repMap)
373 filePath = os.path.join(path,
"TkAlMerge.sh")
374 theFile = open( filePath,
"w" )
375 theFile.write(
replaceByMap( configTemplates.mergeTemplate, repMap ) )
377 os.chmod(filePath,0755)
382 if config.has_section(
"alternateTemplates"):
383 for templateName
in config.options(
"alternateTemplates"):
384 if templateName ==
"AutoAlternates":
386 newTemplateName = config.get(
"alternateTemplates", templateName )
395 optParser = optparse.OptionParser()
396 optParser.description =
"""All-in-one Alignment Validation.
397 This will run various validation procedures either on batch queues or interactively.
398 If no name is given (-N parameter) a name containing time and date is created automatically.
399 To merge the outcome of all validation procedures run TkAlMerge.sh in your validation's directory.
401 optParser.add_option(
"-n",
"--dryRun", dest=
"dryRun", action=
"store_true", default=
False,
402 help=
"create all scripts and cfg File but do not start jobs (default=False)")
403 optParser.add_option(
"--getImages", dest=
"getImages", action=
"store_true", default=
True,
404 help=
"get all Images created during the process (default= True)")
405 defaultConfig =
"TkAlConfig.ini"
406 optParser.add_option(
"-c",
"--config", dest=
"config", default = defaultConfig,
407 help=
"configuration to use (default TkAlConfig.ini) this can be a comma-seperated list of all .ini file you want to merge", metavar=
"CONFIG")
408 optParser.add_option(
"-N",
"--Name", dest=
"Name",
409 help=
"Name of this validation (default: alignmentValidation_DATE_TIME)", metavar=
"NAME")
410 optParser.add_option(
"-r",
"--restrictTo", dest=
"restrictTo",
411 help=
"restrict validations to given modes (comma seperated) (default: no restriction)", metavar=
"RESTRICTTO")
412 optParser.add_option(
"-s",
"--status", dest=
"crabStatus", action=
"store_true", default =
False,
413 help=
"get the status of the crab jobs", metavar=
"STATUS")
414 optParser.add_option(
"-d",
"--debug", dest=
"debugMode", action=
"store_true",
416 help=
"run the tool to get full traceback of errors",
418 optParser.add_option(
"-m",
"--autoMerge", dest=
"autoMerge", action=
"store_true", default =
False,
419 help=
"submit TkAlMerge.sh to run automatically when all jobs have finished (default=False)."
420 " Works only for batch jobs")
422 (options, args) = optParser.parse_args(argv)
424 if not options.restrictTo ==
None:
425 options.restrictTo = options.restrictTo.split(
",")
427 options.config = [ os.path.abspath( iniFile )
for iniFile
in \
428 options.config.split(
"," ) ]
429 config = BetterConfigParser()
430 outputIniFileSet = set( config.read( options.config ) )
431 failedIniFiles = [ iniFile
for iniFile
in options.config
if iniFile
not in outputIniFileSet ]
434 if options.config == [ os.path.abspath( defaultConfig ) ]:
435 if (
not options.crabStatus )
and \
436 (
not os.path.exists( defaultConfig ) ):
437 raise AllInOneError, (
"Default 'ini' file '%s' not found!\n"
438 "You can specify another name with the "
439 "command line option '-c'/'--config'."
442 for iniFile
in failedIniFiles:
443 if not os.path.exists( iniFile ):
444 raise AllInOneError, (
"'%s' does not exist. Please check for "
445 "typos in the filename passed to the "
446 "'-c'/'--config' option!"
449 raise AllInOneError, (
"'%s' does exist, but parsing of the "
450 "content failed!" ) % iniFile
453 if options.Name ==
None:
454 if not options.crabStatus:
455 options.Name =
"alignmentValidation_%s"%(datetime.datetime.now().strftime(
"%y%m%d_%H%M%S"))
457 existingValDirs = fnmatch.filter( os.walk(
'.' ).
next()[1],
458 "alignmentValidation_*" )
459 if len( existingValDirs ) > 0:
460 options.Name = existingValDirs[-1]
462 print "Cannot guess last working directory!"
463 print (
"Please use the parameter '-N' or '--Name' to specify "
464 "the task for which you want a status report." )
468 outPath = os.path.abspath( options.Name )
471 if options.crabStatus:
473 crabLogDirs = fnmatch.filter( os.walk(
'.').
next()[1],
"crab.*" )
474 if len( crabLogDirs ) == 0:
475 print "Found no crab tasks for job name '%s'"%( options.Name )
478 for crabLogDir
in crabLogDirs:
480 print "*" +
"=" * 78 +
"*"
481 print (
"| Status report and output retrieval for:"
482 +
" " * (77 - len(
"Status report and output retrieval for:" ) )
484 taskName = crabLogDir.replace(
"crab.",
"" )
485 print "| " + taskName +
" " * (77 - len( taskName ) ) +
"|"
486 print "*" +
"=" * 78 +
"*"
488 crabOptions = {
"-getoutput":
"",
491 theCrab.run( crabOptions )
492 except AllInOneError, e:
493 print "crab: No output retrieved for this task."
494 crabOptions = {
"-status":
"",
496 theCrab.run( crabOptions )
499 general = config.getGeneral()
500 config.set(
"internals",
"workdir",os.path.join(general[
"workdir"],options.Name) )
501 config.set(
"general",
"datadir",os.path.join(general[
"datadir"],options.Name) )
502 config.set(
"general",
"logdir",os.path.join(general[
"logdir"],options.Name) )
503 config.set(
"general",
"eosdir",os.path.join(
"AlignmentValidation", general[
"eosdir"], options.Name) )
505 if not os.path.exists( outPath ):
506 os.makedirs( outPath )
507 elif not os.path.isdir( outPath ):
508 raise AllInOneError,
"the file %s is in the way rename the Job or move it away"%outPath
514 backupConfigFile = open( os.path.join( outPath,
"usedConfiguration.ini" ) ,
"w" )
515 config.write( backupConfigFile )
518 for validation
in config.items(
"validation"):
519 alignmentList = [validation[1]]
520 validationsToAdd = [(validation[0],alignment) \
521 for alignment
in alignmentList]
522 validations.extend(validationsToAdd)
524 for validation
in validations ]
525 map(
lambda job: job.createJob(), jobs )
526 validations = [ job.getValidation()
for job
in jobs ]
531 map(
lambda job: job.runJob(), jobs )
533 if options.autoMerge:
536 if ValidationJob.jobCount == ValidationJob.batchCount
and config.getGeneral()[
"jobmode"].
split(
",")[0] ==
"lxBatch":
537 print "> Automatically merging jobs when they have ended"
539 "commands": config.getGeneral()[
"jobmode"].
split(
",")[1],
540 "jobName":
"TkAlMerge",
541 "logDir": config.getGeneral()[
"logdir"],
542 "script":
"TkAlMerge.sh",
543 "bsub":
"/afs/cern.ch/cms/caf/scripts/cmsbsub",
544 "conditions":
'"' +
" && ".
join([
"ended(" + jobId +
")" for jobId
in ValidationJob.batchJobIds]) +
'"'
546 for ext
in (
"stdout",
"stderr",
"stdout.gz",
"stderr.gz"):
547 oldlog =
"%(logDir)s/%(jobName)s."%repMap + ext
548 if os.path.exists(oldlog):
552 "-o %(logDir)s/%(jobName)s.stdout "
553 "-e %(logDir)s/%(jobName)s.stderr "
555 "%(logDir)s/%(script)s"%repMap)
557 if __name__ ==
"__main__":
559 if "-d" in sys.argv[1:]
or "--debug" in sys.argv[1:]:
564 except AllInOneError, e:
565 print "\nAll-In-One Tool:", str(e)
def createTrackSplitPlotScript
— Classes —############################
def createOfflineParJobsMergeScript
def main
— Main —############################
def createExtendedValidationScript
def alternateTemplate
### Alternate Templates ###
if(c.getParameter< edm::InputTag >("puppiValueMap").label().size()!=0)
static std::string join(char **cmd)
def replaceByMap
— Helpers —############################