Reference Manual

def production_tasks.BaseDataset.addOption	(	self,
		parser
	)

Definition at line 117 of file production_tasks.py.

117

118 def addOption(self, parser):

parser.add_option("-n", "--name", dest="name", default=None,help='The name of the dataset in DAS. Will be guessed if not specified')

production_tasks.BaseDataset.addOption

def addOption

Definition: production_tasks.py:117

def production_tasks.BaseDataset.query	(	self,
		dataset
	)

Query DAS to find out how many events are in the dataset

Definition at line 119 of file production_tasks.py.

References DDVectorGetter.check(), CalibratedPatElectronProducer.dataset, production_tasks.Task.dataset, CalibratedElectronProducer.dataset, edmIntegrityCheck.IntegrityCheck.dataset, and genericValidation.GenericValidationData.dataset.

Referenced by production_tasks.BaseDataset.run().

 
     def query(self, dataset):
         """Query DAS to find out how many events are in the dataset"""
 
         host    = self.options.host
         debug   = self.options.verbose
         idx     = self.options.idx
         limit   = self.options.limit
         
         def check(ds):
             query = 'dataset=%s' % ds
             result = Das.get_data(host, query, idx, limit, debug)
             result = result.replace('null','None')
             result = result.replace('true','True')
             result = result.replace('false','False')
             data = eval(result)
             if data['status'] != 'ok':
                 raise Exception("Das query failed: Output is '%s'" % data)
             return (data['data'],data)
 
         data = None
         exists = False
         
         if self.options.name is None:
             #guess the dataset name in DBS
             tokens = [t for t in dataset.split(os.sep) if t]
             if len(tokens) >= 3:
                 #DBS names always have three entries
                 ds = os.sep + os.sep.join(tokens[0:3])
                 if ds:
                     exists, data = check(ds)
                     self.options.name = ds
         else:
             exists, data = check(self.options.name)
             if not exists:
                 raise Exception("Specified dataset '%s' not found in Das. Please check." % self.options.name)
         
         if data is None:
             raise Exception("Dataset '%s' not found in Das. Please check." % self.dataset)
         return data

DDVectorGetter::check

bool check(const std::string &)

Definition: DDVectorGetter.h:15

Exception

production_tasks.Task.dataset

dataset

Definition: production_tasks.py:29

production_tasks.BaseDataset.query

def query

Definition: production_tasks.py:119

def production_tasks.BaseDataset.run	(	self,
		input
	)

Definition at line 159 of file production_tasks.py.

References CalibratedPatElectronProducer.dataset, production_tasks.Task.dataset, CalibratedElectronProducer.dataset, edmIntegrityCheck.IntegrityCheck.dataset, genericValidation.GenericValidationData.dataset, FileExportPlugin.FileExportPlugin.options, cmsswPreprocessor.CmsswPreprocessor.options, DOTExport.DotProducer.options, confdb.HLTProcess.options, production_tasks.Task.options, edmIntegrityCheck.IntegrityCheck.options, DbQuery.query, edmIntegrityCheck.IntegrityCheck.query(), confdbOfflineConverter.OfflineConverter.query(), production_tasks.BaseDataset.query(), ora::QueryableVector< Tp >.query(), and upload_popcon.HTTP.query().

 
     def run(self, input):
         output = {}
         if (hasattr(self.options,'check') and self.options.check) or not hasattr(self.options,'check'):
             output = self.query(self.dataset)
         return {'Name':self.options.name,'Das':output}

production_tasks.BaseDataset.run

def run

Definition: production_tasks.py:159

production_tasks.Task.options

options

Definition: production_tasks.py:31

production_tasks.Task.dataset

dataset

Definition: production_tasks.py:29

production_tasks.BaseDataset.query

def query

Definition: production_tasks.py:119

Additional Inherited Members
Public Attributes inherited from production_tasks.Task
	dataset

	instance

	name

	options

	user

def production_tasks.BaseDataset.__init__	(	self,
		dataset,
		user,
		options
	)

Public Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Public Member Functions
def	__init__

def	addOption

def	query

def	run

Public Member Functions inherited from production_tasks.Task
def	__init__

def	addOption

def	getname

def	run