validateAlignments.ParallelMergeJob Class Reference

— Classes —############################ More...

Public Member Functions
def	__init__ (self, _name, _path, _dependency)
def	addDependency (self, dependency)
def	runJob (self, config)

Public Attributes
	dependencies
	name
	path

Detailed Description

— Classes —############################

Definition at line 45 of file validateAlignments.py.

Constructor & Destructor Documentation

def validateAlignments.ParallelMergeJob.__init__	(		self,
			_name,
			_path,
			_dependency
	)

Definition at line 47 of file validateAlignments.py.

    def __init__(self, _name, _path, _dependency):
        self.name=_name
        self.path=_path
        self.dependencies=_dependency

Member Function Documentation

def validateAlignments.ParallelMergeJob.addDependency	(		self,
			dependency
	)

Definition at line 51 of file validateAlignments.py.

    def addDependency(self,dependency):
        if isinstance(dependency,list):
            self.dependencies.extend(dependency)
        else:
            self.dependencies.append(dependency)

def validateAlignments.ParallelMergeJob.runJob	(		self,
			config
	)

Definition at line 56 of file validateAlignments.py.

References validateAlignments.ParallelMergeJob.dependencies, helperFunctions.getCommandOutput2(), join(), AlignableObjectId::entry.name, preexistingValidation.PreexistingValidation.name, alignment.Alignment.name, validateAlignments.ParallelMergeJob.name, genericValidation.GenericValidation.name, TrackerSectorStruct.name, classes.MonitorData.name, MuonGeometrySanityCheckPoint.name, classes.OutputData.name, geometry.Structure.name, plotscripts.SawTeethFunction.name, presentation.ValidationPlots.path, validateAlignments.ParallelMergeJob.path, and split.

    def runJob(self, config):
        repMap = {
        "commands": config.getGeneral()["jobmode"].split(",")[1],
        "jobName": self.name,
        "logDir": config.getGeneral()["logdir"],
        "script": self.path,
        "bsub": "/afs/cern.ch/cms/caf/scripts/cmsbsub",
        "conditions": '"' + " && ".join(["ended(" + jobId + ")" for jobId in self.dependencies]) + '"'
        }
        return getCommandOutput2("%(bsub)s %(commands)s "
            "-J %(jobName)s "
            "-o %(logDir)s/%(jobName)s.stdout "
            "-e %(logDir)s/%(jobName)s.stderr "
            "-w %(conditions)s "
            "%(script)s"%repMap)

Member Data Documentation

validateAlignments.ParallelMergeJob.dependencies

Definition at line 50 of file validateAlignments.py.

Referenced by TreeCrawler.Package.dump(), and validateAlignments.ParallelMergeJob.runJob().

validateAlignments.ParallelMergeJob.name

Definition at line 48 of file validateAlignments.py.

Referenced by ElectronMVAID.ElectronMVAID.__call__(), dirstructure.Directory.__create_pie_image(), DisplayManager.DisplayManager.__del__(), dqm_interfaces.DirID.__eq__(), BeautifulSoup.Tag.__eq__(), dirstructure.Directory.__get_full_path(), dirstructure.Comparison.__get_img_name(), dataset.Dataset.__getDataType(), dataset.Dataset.__getFileInfoList(), dirstructure.Comparison.__make_image(), core.autovars.NTupleVariable.__repr__(), core.autovars.NTupleObjectType.__repr__(), core.autovars.NTupleObject.__repr__(), core.autovars.NTupleCollection.__repr__(), dirstructure.Directory.__repr__(), dqm_interfaces.DirID.__repr__(), dirstructure.Comparison.__repr__(), config.Service.__setattr__(), config.CFG.__str__(), counter.Counter.__str__(), average.Average.__str__(), BeautifulSoup.Tag.__str__(), BeautifulSoup.SoupStrainer.__str__(), core.autovars.NTupleObjectType.addSubObjects(), core.autovars.NTupleObjectType.addVariables(), core.autovars.NTupleObjectType.allVars(), dirstructure.Directory.calcStats(), crabFunctions.CrabTask.crabConfig(), crabFunctions.CrabTask.crabFolder(), validation.Sample.digest(), python.rootplot.utilities.Hist.divide(), python.rootplot.utilities.Hist.divide_wilson(), DisplayManager.DisplayManager.Draw(), TreeCrawler.Package.dump(), core.autovars.NTupleVariable.fillBranch(), core.autovars.NTupleObject.fillBranches(), core.autovars.NTupleCollection.fillBranchesScalar(), core.autovars.NTupleCollection.fillBranchesVector(), core.autovars.NTupleCollection.get_cpp_declaration(), core.autovars.NTupleCollection.get_cpp_wrapper_class(), core.autovars.NTupleCollection.get_py_wrapper_class(), utils.StatisticalTest.get_status(), production_tasks.Task.getname(), dataset.CMSDataset.getPrimaryDatasetEntries(), dataset.PrivateDataset.getPrimaryDatasetEntries(), crabFunctions.CrabTask.handleNoState(), VIDSelectorBase.VIDSelectorBase.initialize(), personalPlayback.Applet.log(), core.autovars.NTupleVariable.makeBranch(), core.autovars.NTupleObject.makeBranches(), core.autovars.NTupleCollection.makeBranchesScalar(), core.autovars.NTupleCollection.makeBranchesVector(), dirstructure.Directory.print_report(), dataset.BaseDataset.printInfo(), dataset.Dataset.printInfo(), crabFunctions.CrabTask.resubmit_failed(), production_tasks.MonitorJobs.run(), validateAlignments.ParallelMergeJob.runJob(), BeautifulSoup.SoupStrainer.searchTag(), python.rootplot.utilities.Hist.TGraph(), python.rootplot.utilities.Hist.TH1F(), crabFunctions.CrabTask.update(), crabFunctions.CrabTask.updateJobStats(), Vispa.Views.PropertyView.Property.valueChanged(), counter.Counter.write(), and average.Average.write().

validateAlignments.ParallelMergeJob.path

Definition at line 49 of file validateAlignments.py.

Referenced by python.rootplot.rootmath.Target.__repr__(), and validateAlignments.ParallelMergeJob.runJob().