CMS 3D CMS Logo
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Public Member Functions | Private Member Functions | Private Attributes | Static Private Attributes
dataset.Dataset Class Reference

Public Member Functions

def __init__
 
def convertTimeToRun
 
def datasetSnippet
 
def dataType
 
def dump_cff
 
def fileInfoList
 
def fileList
 
def name
 
def predefined
 
def runList
 

Private Member Functions

def __chunks
 
def __createSnippet
 
def __find_ge
 
def __find_lt
 
def __getData
 
def __getDataType
 
def __getFileInfoList
 
def __getRunList
 

Private Attributes

 __dasLimit
 
 __dataType
 
 __fileInfoList
 
 __fileList
 
 __name
 
 __predefined
 
 __runList
 

Static Private Attributes

tuple __dummy_source_template
 

Detailed Description

Definition at line 13 of file dataset.py.

Constructor & Destructor Documentation

def dataset.Dataset.__init__ (   self,
  datasetName,
  dasLimit = 0 
)

Definition at line 14 of file dataset.py.

14 
15  def __init__( self, datasetName, dasLimit = 0 ):
16  self.__name = datasetName
17  # check, if dataset name matches CMS dataset naming scheme
18  if re.match( r'/.+/.+/.+', self.__name ):
19  self.__dataType = self.__getDataType()
20  self.__predefined = False
21  else:
22  fileName = self.__name + "_cff.py"
23  searchPath1 = os.path.join( os.environ["CMSSW_BASE"], "python",
24  "Alignment", "OfflineValidation",
25  fileName )
26  searchPath2 = os.path.join( os.environ["CMSSW_BASE"], "src",
27  "Alignment", "OfflineValidation",
28  "python", fileName )
29  searchPath3 = os.path.join( os.environ["CMSSW_RELEASE_BASE"],
30  "python", "Alignment",
31  "OfflineValidation", fileName )
32  if os.path.exists( searchPath1 ):
33  pass
34  elif os.path.exists( searchPath2 ):
35  msg = ("The predefined dataset '%s' does exist in '%s', but "
36  "you need to run 'scram b' first."
37  %( self.__name, searchPath2 ))
38  raise AllInOneError( msg )
39  elif os.path.exists( searchPath3 ):
40  pass
41  else:
42  msg = ("The predefined dataset '%s' does not exist. Please "
43  "create it first or check for typos."%( self.__name ))
44  raise AllInOneError( msg )
45  self.__dataType = "unknown"
46  self.__predefined = True
47  self.__dasLimit = dasLimit
48  self.__fileList = None
49  self.__fileInfoList = None
50  self.__runList = None
dataset.Dataset.__getDataType
def __getDataType
Definition: dataset.py:185

Member Function Documentation

def dataset.Dataset.__chunks (   self,
  theList,
  n 
)
private 
Yield successive n-sized chunks from theList.

Definition at line 51 of file dataset.py.

References dataset.Dataset.__createSnippet().

Referenced by dataset.Dataset.__createSnippet().

51 
52  def __chunks( self, theList, n ):
53  """ Yield successive n-sized chunks from theList.
54  """
55  for i in xrange( 0, len( theList ), n ):
56  yield theList[i:i+n]
def dataset.Dataset.__createSnippet (   self,
  jsonPath = None,
  begin = None,
  end = None,
  firstRun = None,
  lastRun = None,
  repMap = None,
  crab = False 
)
private

Definition at line 59 of file dataset.py.

References dataset.Dataset.__chunks(), dataset.Dataset.__dummy_source_template, dataset.Dataset.__getRunList(), dataset.Dataset.convertTimeToRun(), dataset.Dataset.fileList(), join(), list(), and split.

Referenced by dataset.Dataset.__chunks(), dataset.Dataset.datasetSnippet(), and dataset.Dataset.dump_cff().

59 
60  crab = False ):
61  if firstRun:
62  firstRun = int( firstRun )
63  if lastRun:
64  lastRun = int( lastRun )
65  if ( begin and firstRun ) or ( end and lastRun ):
66  msg = ( "The Usage of "
67  + "'begin' & 'firstRun' " * int( bool( begin and
68  firstRun ) )
69  + "and " * int( bool( ( begin and firstRun ) and
70  ( end and lastRun ) ) )
71  + "'end' & 'lastRun' " * int( bool( end and lastRun ) )
72  + "is ambigous." )
73  raise AllInOneError( msg )
74  if begin or end:
75  ( firstRun, lastRun ) = self.convertTimeToRun(
76  begin = begin, end = end, firstRun = firstRun,
77  lastRun = lastRun )
78  if ( firstRun and lastRun ) and ( firstRun > lastRun ):
79  msg = ( "The lower time/runrange limit ('begin'/'firstRun') "
80  "chosen is greater than the upper time/runrange limit "
81  "('end'/'lastRun').")
82  raise AllInOneError( msg )
83  goodLumiSecStr = ""
84  lumiStr = ""
85  lumiSecExtend = ""
86  if firstRun or lastRun:
87  goodLumiSecStr = ( "lumiSecs = cms.untracked."
88  "VLuminosityBlockRange()\n" )
89  lumiStr = " lumisToProcess = lumiSecs,\n"
90  if not jsonPath:
91  selectedRunList = self.__getRunList()
92  if firstRun:
93  selectedRunList = [ run for run in selectedRunList \
94  if run["run_number"] >= firstRun ]
95  if lastRun:
96  selectedRunList = [ run for run in selectedRunList \
97  if run["run_number"] <= lastRun ]
98  lumiList = [ str( run["run_number"] ) + ":1-" \
99  + str( run["run_number"] ) + ":max" \
100  for run in selectedRunList ]
101  splitLumiList = list( self.__chunks( lumiList, 255 ) )
102  else:
103  theLumiList = LumiList ( filename = jsonPath )
104  allRuns = theLumiList.getRuns()
105  runsToRemove = []
106  for run in allRuns:
107  if firstRun and int( run ) < firstRun:
108  runsToRemove.append( run )
109  if lastRun and int( run ) > lastRun:
110  runsToRemove.append( run )
111  theLumiList.removeRuns( runsToRemove )
112  splitLumiList = list( self.__chunks(
113  theLumiList.getCMSSWString().split(','), 255 ) )
114  if not len(splitLumiList[0][0]) == 0:
115  lumiSecStr = [ "',\n'".join( lumis ) \
116  for lumis in splitLumiList ]
117  lumiSecStr = [ "lumiSecs.extend( [\n'" + lumis + "'\n] )" \
118  for lumis in lumiSecStr ]
119  lumiSecExtend = "\n".join( lumiSecStr )
120  elif jsonPath:
121  goodLumiSecStr = ( "goodLumiSecs = LumiList.LumiList(filename"
122  "= '%(json)s').getCMSSWString().split(',')\n"
123  "lumiSecs = cms.untracked"
124  ".VLuminosityBlockRange()\n"
125  )
126  lumiStr = " lumisToProcess = lumiSecs,\n"
127  lumiSecExtend = "lumiSecs.extend(goodLumiSecs)\n"
128  if crab:
129  files = ""
130  else:
131  splitFileList = list( self.__chunks( self.fileList(), 255 ) )
132  fileStr = [ "',\n'".join( files ) for files in splitFileList ]
133  fileStr = [ "readFiles.extend( [\n'" + files + "'\n] )" \
134  for files in fileStr ]
135  files = "\n".join( fileStr )
136  theMap = repMap
137  theMap["files"] = files
138  theMap["json"] = jsonPath
139  theMap["lumiStr"] = lumiStr
140  theMap["goodLumiSecStr"] = goodLumiSecStr%( theMap )
141  theMap["lumiSecExtend"] = lumiSecExtend
142  if crab:
143  dataset_snippet = self.__dummy_source_template%( theMap )
144  else:
145  dataset_snippet = self.__source_template%( theMap )
146  return dataset_snippet
dataset.Dataset.convertTimeToRun
def convertTimeToRun
Definition: dataset.py:263
join
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
dataset.Dataset.__dummy_source_template
tuple __dummy_source_template
Definition: dataset.py:147
dataset.Dataset.__getRunList
def __getRunList
Definition: dataset.py:232
split
double split
Definition: MVATrainer.cc:139
list
How EventSelector::AcceptEvent() decides whether to accept an event for output otherwise it is excluding the probing of A single or multiple positive and the trigger will pass if any such matching triggers are PASS or EXCEPTION[A criterion thatmatches no triggers at all is detected and causes a throw.] A single negative with an expectation of appropriate bit checking in the decision and the trigger will pass if any such matching triggers are FAIL or EXCEPTION A wildcarded negative criterion that matches more than one trigger in the trigger list("!*","!HLTx*"if it matches 2 triggers or more) will accept the event if all the matching triggers are FAIL.It will reject the event if any of the triggers are PASS or EXCEPTION(this matches the behavior of"!*"before the partial wildcard feature was incorporated).Triggers which are in the READY state are completely ignored.(READY should never be returned since the trigger paths have been run
def dataset.Dataset.__find_ge (   self,
  a,
  x 
)
private

Definition at line 165 of file dataset.py.

Referenced by dataset.Dataset.convertTimeToRun().

165 
166  def __find_ge( self, a, x):
167  'Find leftmost item greater than or equal to x'
168  i = bisect.bisect_left( a, x )
169  if i != len( a ):
170  return i
171  raise ValueError
def dataset.Dataset.__find_lt (   self,
  a,
  x 
)
private

Definition at line 158 of file dataset.py.

Referenced by dataset.Dataset.convertTimeToRun().

158 
159  def __find_lt( self, a, x ):
160  'Find rightmost value less than x'
161  i = bisect.bisect_left( a, x )
162  if i:
163  return i-1
164  raise ValueError
def dataset.Dataset.__getData (   self,
  dasQuery,
  dasLimit = 0 
)
private

Definition at line 172 of file dataset.py.

Referenced by dataset.Dataset.__getDataType(), dataset.Dataset.__getFileInfoList(), and dataset.Dataset.__getRunList().

172 
173  def __getData( self, dasQuery, dasLimit = 0 ):
174  dasData = das_client.get_data( 'https://cmsweb.cern.ch',
175  dasQuery, 0, dasLimit, False )
176  if isinstance(dasData, str):
177  jsondict = json.loads( dasData )
178  else:
179  jsondict = dasData
180  # Check, if the DAS query fails
181  if jsondict["status"] != 'ok':
182  msg = "Status not 'ok', but:", jsondict["status"]
183  raise AllInOneError(msg)
184  return jsondict["data"]
def dataset.Dataset.__getDataType (   self)
private

Definition at line 185 of file dataset.py.

References dataset.Dataset.__getData(), dataset.Dataset.__name, cond::TagInfo.name, profilereader.FunctionInfo.name, genericValidation.GenericValidation.name, TmModule.name, Select.name, ora::RecordSpecImpl::Item.name, alignment.Alignment.name, FWTGeoRecoGeometry::Info.name, GifDisplay.name, Button.name, Types._Untracked.name, MyWatcher.name, PixelDCSObject< class >::Item.name, HistoDef.name(), fit::RootMinuitCommand.name, ParameterSet.name, HcalForwardLibWriter::FileHandle.name, SeedingLayerSetsBuilder::LayerSpec.name, DQMRivetClient::LumiOption.name, MagCylinder.name, PFTauMVAInputDiscriminantTranslator::DiscriminantInfo.name, PrintSensitive.name, ALIFileOut.name(), RHStopTracer::StopPoint.name, CombinedMVAJetTagComputer::Computer.name, DQMRivetClient::ScaleFactorOption.name, runEdmFileComparison.EdmObject.name, EgHLTOfflineSummaryClient::SumHistBinData.name, HistoData.name, PhysicsTools::Source.name, CSCDCCExaminer::OStream.name, lumi::TriggerInfo.name, XMLHTRZeroSuppressionLoader::_loaderBaseConfig.name, SingleObjectCondition.name, XMLRBXPedestalsLoader::_loaderBaseConfig.name, cond::TimeTypeSpecs.name, PrintMaterialBudgetInfo.name, ALIFileIn.name(), MagVolume6Faces.name, DQMGenericClient::EfficOption.name, edm::PathSummary.name, dirstructure.Weighted.name, PixelEndcapLinkMaker::Item.name, perftools::EdmEventSize::BranchRecord.name, FWTableViewManager::TableEntry.name, PixelBarrelLinkMaker::Item.name, Mapper::definition< ScannerT >.name, options.ConnectionHLTMenu.name, EcalLogicID.name, McSelector.name, ExpressionHisto< T >.name, MEtoEDM< T >::MEtoEDMObject.name, LinuxElapsedTime.name, RecoSelector.name, python.rootplot.utilities.Hist2D.name, Entry.name(), TreeCrawler.Package.name, CaloTrkProcessing::Detector.name, SensitiveDetector.name, XMLProcessor::_loaderBaseConfig.name, PrintGeomInfoAction.name, MagGeoBuilderFromDDD::volumeHandle.name, DQMGenericClient::NormOption.name, PhysicsTools::Calibration::Variable.name, OpticalObject.name(), DQMGenericClient::CDOption.name, h4DSegm.name, PhysicsTools::Variable::Value.name, options.HLTProcessOptions.name, EDMtoMEConverter.name, ProcTMVA::Method.name, TreeSaver::Var.name, python.rootplot.tree2hists.Plot.name, PhysicsTools::TrainProcessor.name, MuonGeometrySanityCheckPoint.name, Measurement.name(), PhysicsTools::TreeReader::Value.name, TotemSD.name, PhysicsTools::MVAModuleHelper< Record, Object, Filler >::Value.name, PhysicsTools::ProcessRegistry< Base_t, CalibBase_t, Parent_t >.name, utils.StatisticalTest.name, PhysicsTools::MVATrainer.name, EfficiencyHandler.name, h2DSegm.name, python.rootplot.utilities.Hist.name, BscSD.name, DQMNet::WaitObject.name, stor::DataSenderMonitorCollection::OutputModuleRecord.name, SiStripMonitorDigi.name, AlpgenParameterName.name, FP420SD.name, Vardesc.name, public_plots_tools.ColorScheme.name, PhysicsTools::Variable.name, Namelist.name, HRes1DHit.name, PhysicsTools::TrainerMonitoring::Object.name, utils.KS.name, stor::DataSenderMonitorCollection::OutputModuleResult.name, utils.Chi2.name, utils_v2.StatisticalTest.name, utils.BinToBin.name, dirstructure.Comparison.name, HEff1DHit.name, utils_v2.KolmogorovTest.name, plotscripts.SawTeethFunction.name, utils_v2.Chi2Test.name, @15930::Id.name, dqm_interfaces.DirID.name, utils.BinToBin1percent.name, dataset.Dataset.name(), python.rootplot.utilities.RootFile.name, hTMaxCell.name, HRes2DHit.name, cscdqm::ParHistoDef.name, BeautifulSoup.Tag.name, dqm_interfaces.DirWalkerFile.name, @15926::Id.name, HEff2DHit.name, TiXmlAttribute.name, BeautifulSoup.SoupStrainer.name, HRes4DHit.name, and HEff4DHit.name.

185 
186  def __getDataType( self ):
187  dasQuery_type = ( 'dataset dataset=%s | grep dataset.datatype,'
188  'dataset.name'%( self.__name ) )
189  data = self.__getData( dasQuery_type )
190  for a in data[0]["dataset"]:
191  if "datatype" in a:
192  return a["datatype"]
193  msg = ("Cannot find the datatype of the dataset '%s'"%( self.name() ))
194  raise AllInOneError( msg )
dataset.Dataset.__getDataType
def __getDataType
Definition: dataset.py:185
def dataset.Dataset.__getFileInfoList (   self,
  dasLimit 
)
private

Definition at line 195 of file dataset.py.

References dataset.Dataset.__fileInfoList, dataset.Dataset.__getData(), dataset.Dataset.__name, cond::TagInfo.name, profilereader.FunctionInfo.name, genericValidation.GenericValidation.name, TmModule.name, Select.name, ora::RecordSpecImpl::Item.name, GifDisplay.name, FWTGeoRecoGeometry::Info.name, alignment.Alignment.name, Button.name, Types._Untracked.name, MyWatcher.name, PixelDCSObject< class >::Item.name, HistoDef.name(), fit::RootMinuitCommand.name, ParameterSet.name, HcalForwardLibWriter::FileHandle.name, SeedingLayerSetsBuilder::LayerSpec.name, DQMRivetClient::LumiOption.name, MagCylinder.name, PFTauMVAInputDiscriminantTranslator::DiscriminantInfo.name, PrintSensitive.name, ALIFileOut.name(), RHStopTracer::StopPoint.name, CombinedMVAJetTagComputer::Computer.name, DQMRivetClient::ScaleFactorOption.name, runEdmFileComparison.EdmObject.name, EgHLTOfflineSummaryClient::SumHistBinData.name, HistoData.name, PhysicsTools::Source.name, SingleObjectCondition.name, XMLRBXPedestalsLoader::_loaderBaseConfig.name, CSCDCCExaminer::OStream.name, lumi::TriggerInfo.name, XMLHTRZeroSuppressionLoader::_loaderBaseConfig.name, cond::TimeTypeSpecs.name, ALIFileIn.name(), PrintMaterialBudgetInfo.name, MagVolume6Faces.name, perftools::EdmEventSize::BranchRecord.name, DQMGenericClient::EfficOption.name, edm::PathSummary.name, dirstructure.Weighted.name, PixelEndcapLinkMaker::Item.name, FWTableViewManager::TableEntry.name, PixelBarrelLinkMaker::Item.name, Mapper::definition< ScannerT >.name, options.ConnectionHLTMenu.name, McSelector.name, EcalLogicID.name, ExpressionHisto< T >.name, MEtoEDM< T >::MEtoEDMObject.name, LinuxElapsedTime.name, RecoSelector.name, python.rootplot.utilities.Hist2D.name, TreeCrawler.Package.name, Entry.name(), XMLProcessor::_loaderBaseConfig.name, CaloTrkProcessing::Detector.name, SensitiveDetector.name, PrintGeomInfoAction.name, MagGeoBuilderFromDDD::volumeHandle.name, DQMGenericClient::NormOption.name, PhysicsTools::Calibration::Variable.name, OpticalObject.name(), DQMGenericClient::CDOption.name, h4DSegm.name, PhysicsTools::Variable::Value.name, options.HLTProcessOptions.name, EDMtoMEConverter.name, ProcTMVA::Method.name, TreeSaver::Var.name, python.rootplot.tree2hists.Plot.name, MuonGeometrySanityCheckPoint.name, PhysicsTools::TrainProcessor.name, Measurement.name(), PhysicsTools::TreeReader::Value.name, TotemSD.name, PhysicsTools::MVAModuleHelper< Record, Object, Filler >::Value.name, PhysicsTools::ProcessRegistry< Base_t, CalibBase_t, Parent_t >.name, utils.StatisticalTest.name, PhysicsTools::MVATrainer.name, EfficiencyHandler.name, h2DSegm.name, python.rootplot.utilities.Hist.name, BscSD.name, stor::DataSenderMonitorCollection::OutputModuleRecord.name, DQMNet::WaitObject.name, SiStripMonitorDigi.name, AlpgenParameterName.name, FP420SD.name, Vardesc.name, public_plots_tools.ColorScheme.name, PhysicsTools::Variable.name, Namelist.name, HRes1DHit.name, PhysicsTools::TrainerMonitoring::Object.name, utils.KS.name, stor::DataSenderMonitorCollection::OutputModuleResult.name, utils.Chi2.name, utils_v2.StatisticalTest.name, utils.BinToBin.name, HEff1DHit.name, dirstructure.Comparison.name, utils_v2.KolmogorovTest.name, plotscripts.SawTeethFunction.name, utils_v2.Chi2Test.name, @15930::Id.name, dqm_interfaces.DirID.name, utils.BinToBin1percent.name, dataset.Dataset.name(), python.rootplot.utilities.RootFile.name, hTMaxCell.name, HRes2DHit.name, cscdqm::ParHistoDef.name, BeautifulSoup.Tag.name, dqm_interfaces.DirWalkerFile.name, @15926::Id.name, HEff2DHit.name, TiXmlAttribute.name, BeautifulSoup.SoupStrainer.name, HRes4DHit.name, and HEff4DHit.name.

Referenced by dataset.Dataset.fileInfoList().

195 
196  def __getFileInfoList( self, dasLimit ):
197  if self.__fileInfoList:
198  return self.__fileInfoList
199  dasQuery_files = ( 'file dataset=%s | grep file.name, file.nevents, '
200  'file.creation_time, '
201  'file.modification_time'%( self.__name ) )
202  print "Requesting file information for '%s' from DAS..."%( self.__name ),
203  data = self.__getData( dasQuery_files, dasLimit )
204  print "Done."
205  data = [ entry["file"] for entry in data ]
206  if len( data ) == 0:
207  msg = ("No files are available for the dataset '%s'. This can be "
208  "due to a typo or due to a DAS problem. Please check the "
209  "spelling of the dataset and/or retry to run "
210  "'validateAlignments.py'."%( self.name() ))
211  raise AllInOneError( msg )
212  fileInformationList = []
213  for file in data:
214  fileName = file[0]["name"]
215  fileCreationTime = file[0]["creation_time"]
216  for ii in range(3):
217  try:
218  fileNEvents = file[ii]["nevents"]
219  except KeyError:
220  continue
221  break
222  # select only non-empty files
223  if fileNEvents == 0:
224  continue
225  fileDict = { "name": fileName,
226  "creation_time": fileCreationTime,
227  "nevents": fileNEvents
228  }
229  fileInformationList.append( fileDict )
230  fileInformationList.sort( key=lambda info: info["name"] )
231  return fileInformationList
dataset.Dataset.__getFileInfoList
def __getFileInfoList
Definition: dataset.py:195
def dataset.Dataset.__getRunList (   self)
private

Definition at line 232 of file dataset.py.

References dataset.Dataset.__getData(), dataset.Dataset.__name, dataset.Dataset.__runList, and dataset.Dataset.convertTimeToRun().

Referenced by dataset.Dataset.__createSnippet(), dataset.Dataset.convertTimeToRun(), and dataset.Dataset.runList().

232 
233  def __getRunList( self ):
234  if self.__runList:
235  return self.__runList
236  dasQuery_runs = ( 'run dataset=%s | grep run.run_number,'
237  'run.creation_time'%( self.__name ) )
238  print "Requesting run information for '%s' from DAS..."%( self.__name ),
239  data = self.__getData( dasQuery_runs )
240  print "Done."
241  data = [ entry["run"][0] for entry in data ]
242  data.sort( key = lambda run: run["creation_time"] )
243  self.__runList = data
244  return data
dataset.Dataset.__getRunList
def __getRunList
Definition: dataset.py:232
def dataset.Dataset.convertTimeToRun (   self,
  begin = None,
  end = None,
  firstRun = None,
  lastRun = None,
  shortTuple = True 
)

Definition at line 263 of file dataset.py.

References dataset.Dataset.__find_ge(), dataset.Dataset.__find_lt(), dataset.Dataset.__getRunList(), and dataset.Dataset.__name.

Referenced by dataset.Dataset.__createSnippet(), and dataset.Dataset.__getRunList().

263 
264  shortTuple = True ):
265  if ( begin and firstRun ) or ( end and lastRun ):
266  msg = ( "The Usage of "
267  + "'begin' & 'firstRun' " * int( bool( begin and
268  firstRun ) )
269  + "and " * int( bool( ( begin and firstRun ) and
270  ( end and lastRun ) ) )
271  + "'end' & 'lastRun' " * int( bool( end and lastRun ) )
272  + "is ambigous." )
273  raise AllInOneError( msg )
274 
275  runList = [ run["run_number"] for run in self.__getRunList() ]
276  runTimeList = [ run["creation_time"] for run in self.__getRunList() ]
277  if begin:
278  try:
279  runIndex = self.__find_ge( runTimeList, begin )
280  except ValueError:
281  msg = ( "Your 'begin' is after the creation time of the last "
282  "run in the dataset\n'%s'"%( self.__name ) )
283  raise AllInOneError( msg )
284  firstRun = runList[runIndex]
285  begin = None
286  if end:
287  try:
288  runIndex = self.__find_lt( runTimeList, end )
289  except ValueError:
290  msg = ( "Your 'end' is before the creation time of the first "
291  "run in the dataset\n'%s'"%( self.__name ) )
292  raise AllInOneError( msg )
293  lastRun = runList[runIndex]
294  end = None
295  if shortTuple:
296  return firstRun, lastRun
297  else:
298  return begin, end, firstRun, lastRun
dataset.Dataset.__getRunList
def __getRunList
Definition: dataset.py:232
def dataset.Dataset.datasetSnippet (   self,
  jsonPath = None,
  begin = None,
  end = None,
  firstRun = None,
  lastRun = None,
  nEvents = None,
  crab = False 
)

Definition at line 304 of file dataset.py.

References dataset.Dataset.__createSnippet(), dataset.Dataset.__name, dataset.Dataset.__predefined, and dataset.Dataset.dump_cff().

Referenced by dataset.Dataset.dataType().

304 
305  crab = False ):
306  if self.__predefined:
307  return ("process.load(\"Alignment.OfflineValidation.%s_cff\")\n"
308  "process.maxEvents = cms.untracked.PSet(\n"
309  " input = cms.untracked.int32(%s)\n"
310  ")"
311  %( self.__name, nEvents ))
312  theMap = { "process": "process.",
313  "tab": " " * len( "process." ),
314  "nEvents": str( nEvents ),
315  "importCms": ""
316  }
317  datasetSnippet = self.__createSnippet( jsonPath = jsonPath,
318  begin = begin,
319  end = end,
320  firstRun = firstRun,
321  lastRun = lastRun,
322  repMap = theMap,
323  crab = crab )
324  return datasetSnippet
dataset.Dataset.__createSnippet
def __createSnippet
Definition: dataset.py:59
def dataset.Dataset.dataType (   self)

Definition at line 299 of file dataset.py.

References dataset.Dataset.__dataType, and dataset.Dataset.datasetSnippet().

299 
300  def dataType( self ):
301  return self.__dataType
def dataset.Dataset.dump_cff (   self,
  outName = None,
  jsonPath = None,
  begin = None,
  end = None,
  firstRun = None,
  lastRun = None 
)

Definition at line 326 of file dataset.py.

References dataset.Dataset.__createSnippet().

Referenced by dataset.Dataset.datasetSnippet().

326 
327  end = None, firstRun = None, lastRun = None ):
328  if outName == None:
329  outName = "Dataset"
330  packageName = os.path.join( "Alignment", "OfflineValidation" )
331  if not os.path.exists( os.path.join(
332  os.environ["CMSSW_BASE"], "src", packageName ) ):
333  msg = ("You try to store the predefined dataset'%s'.\n"
334  "For that you need to check out the package '%s' to your "
335  "private relase area in\n"%( outName, packageName )
336  + os.environ["CMSSW_BASE"] )
337  raise AllInOneError( msg )
338  theMap = { "process": "",
339  "tab": "",
340  "nEvents": str( -1 ),
341  "importCms": "import FWCore.ParameterSet.Config as cms\n" }
342  dataset_cff = self.__createSnippet( jsonPath = jsonPath,
343  begin = begin,
344  end = end,
345  firstRun = firstRun,
346  lastRun = lastRun,
347  repMap = theMap)
348  filePath = os.path.join( os.environ["CMSSW_BASE"], "src", packageName,
349  "python", outName + "_cff.py" )
350  if os.path.exists( filePath ):
351  existMsg = "The predefined dataset '%s' already exists.\n"%( outName )
352  askString = "Do you want to overwrite it? [y/n]\n"
353  inputQuery = existMsg + askString
354  while True:
355  userInput = raw_input( inputQuery ).lower()
356  if userInput == "y":
357  break
358  elif userInput == "n":
359  return
360  else:
361  inputQuery = askString
362  print ( "The predefined dataset '%s' will be stored in the file\n"
363  %( outName )
364  + filePath +
365  "\nFor future use you have to do 'scram b'." )
366  print
367  theFile = open( filePath, "w" )
368  theFile.write( dataset_cff )
369  theFile.close()
370  return
dataset.Dataset.__createSnippet
def __createSnippet
Definition: dataset.py:59
def dataset.Dataset.fileInfoList (   self)

Definition at line 379 of file dataset.py.

References dataset.Dataset.__dasLimit, and dataset.Dataset.__getFileInfoList().

Referenced by dataset.Dataset.fileList().

379 
380  def fileInfoList( self ):
381  return self.__getFileInfoList( self.__dasLimit )
dataset.Dataset.__getFileInfoList
def __getFileInfoList
Definition: dataset.py:195
dataset.Dataset.fileInfoList
def fileInfoList
Definition: dataset.py:379
def dataset.Dataset.fileList (   self)

Definition at line 371 of file dataset.py.

References dataset.Dataset.__fileList, and dataset.Dataset.fileInfoList().

Referenced by dataset.Dataset.__createSnippet().

371 
372  def fileList( self ):
373  if self.__fileList:
374  return self.__fileList
375  fileList = [ fileInfo["name"] \
376  for fileInfo in self.fileInfoList() ]
377  self.__fileList = fileList
378  return fileList
dataset.Dataset.fileInfoList
def fileInfoList
Definition: dataset.py:379
def dataset.Dataset.name (   self)

Definition at line 382 of file dataset.py.

References dataset.Dataset.__name.

Referenced by dataset.Dataset.__getDataType(), dataset.Dataset.__getFileInfoList(), and Vispa.Views.PropertyView.Property.valueChanged().

382 
383  def name( self ):
384  return self.__name
def dataset.Dataset.predefined (   self)

Definition at line 385 of file dataset.py.

References dataset.Dataset.__predefined.

385 
386  def predefined( self ):
387  return self.__predefined
def dataset.Dataset.runList (   self)

Definition at line 388 of file dataset.py.

References dataset.Dataset.__getRunList(), and dataset.Dataset.__runList.

388 
389  def runList( self ):
390  if self.__runList:
391  return self.__runList
392  return self.__getRunList()
393 
dataset.Dataset.__getRunList
def __getRunList
Definition: dataset.py:232

Member Data Documentation

dataset.Dataset.__dasLimit
private

Definition at line 46 of file dataset.py.

Referenced by dataset.Dataset.fileInfoList().

dataset.Dataset.__dataType
private

Definition at line 18 of file dataset.py.

Referenced by dataset.Dataset.dataType().

tuple dataset.Dataset.__dummy_source_template
staticprivate
Initial value:
1 = ("%(process)smaxEvents = cms.untracked.PSet( "
2  "input = cms.untracked.int32(%(nEvents)s) )\n"
3  "readFiles = cms.untracked.vstring()\n"
4  "secFiles = cms.untracked.vstring()\n"
5  "%(process)ssource = cms.Source(\"PoolSource\",\n"
6  "%(tab)s secondaryFileNames ="
7  "secFiles,\n"
8  "%(tab)s fileNames = readFiles\n"
9  ")\n"
10  "readFiles.extend(['dummy_File.root'])\n")

Definition at line 147 of file dataset.py.

Referenced by dataset.Dataset.__createSnippet().

dataset.Dataset.__fileInfoList
private

Definition at line 48 of file dataset.py.

Referenced by dataset.Dataset.__getFileInfoList().

dataset.Dataset.__fileList
private

Definition at line 47 of file dataset.py.

Referenced by dataset.Dataset.fileList().

dataset.Dataset.__name
private

Definition at line 15 of file dataset.py.

Referenced by dataset.Dataset.__getDataType(), dataset.Dataset.__getFileInfoList(), dataset.Dataset.__getRunList(), dataset.Dataset.convertTimeToRun(), dataset.Dataset.datasetSnippet(), Config.Process.dumpConfig(), Config.Process.dumpPython(), dataset.Dataset.name(), and Config.Process.name_().

dataset.Dataset.__predefined
private

Definition at line 19 of file dataset.py.

Referenced by dataset.Dataset.datasetSnippet(), and dataset.Dataset.predefined().

dataset.Dataset.__runList
private

Definition at line 49 of file dataset.py.

Referenced by dataset.Dataset.__getRunList(), and dataset.Dataset.runList().

Generated for CMSSW Reference Manual by doxygen 1.8.5