CMS 3D CMS Logo

List of all members | Public Member Functions
production_tasks.GenerateMask Class Reference
Inheritance diagram for production_tasks.GenerateMask:
production_tasks.Task

Public Member Functions

def __init__ (self, dataset, user, options)
 
def addOption (self, parser)
 
def run (self, input)
 
- Public Member Functions inherited from production_tasks.Task
def __init__ (self, name, dataset, user, options, instance=None)
 
def addOption (self, parser)
 
def getname (self)
 
def run (self, input)
 

Additional Inherited Members

- Public Attributes inherited from production_tasks.Task
 dataset
 
 instance
 
 name
 
 options
 
 user
 

Detailed Description

Uses edmIntegrityCheck.py to generate a file mask for the sample if one is not already present.

Definition at line 279 of file production_tasks.py.

Constructor & Destructor Documentation

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

Definition at line 281 of file production_tasks.py.

281  def __init__(self, dataset, user, options):
282  Task.__init__(self,'GenerateMask', dataset, user, options)
def __init__(self, dataset, user, options)

Member Function Documentation

def production_tasks.GenerateMask.addOption (   self,
  parser 
)

Definition at line 283 of file production_tasks.py.

283  def addOption(self, parser):
284  parser.add_option("-r", "--recursive", dest="resursive", default=False, action='store_true',help='Walk the mass storage device recursively')
285  parser.add_option("-p", "--printout", dest="printout", default=False, action='store_true',help='Print a report to stdout')
def production_tasks.GenerateMask.run (   self,
  input 
)

Definition at line 286 of file production_tasks.py.

References production_tasks.Task.dataset, edmIntegrityCheck.IntegrityCheck.dataset, genericValidation.GenericValidationData.dataset, FileExportPlugin.FileExportPlugin.options, cmsswPreprocessor.CmsswPreprocessor.options, DTCalibrationWorker.DTCalibrationWorker.options, DTWorkflow.DTWorkflow.options, DOTExport.DotProducer.options, TestProcess.TestProcess.options, confdb.HLTProcess.options, production_tasks.Task.options, edmIntegrityCheck.IntegrityCheck.options, validateAlignments.ValidationJobMultiIOV.options, EcalTPGParamReaderFromDB.user, dataset.BaseDataset.user, production_tasks.Task.user, popcon::RpcObGasData.user, popcon::RpcDataT.user, popcon::RPCObPVSSmapData.user, popcon::RpcDataV.user, popcon::RpcDataFebmap.user, popcon::RpcDataGasMix.user, popcon::RpcDataS.user, popcon::RpcDataI.user, popcon::RpcDataUXC.user, MatrixInjector.MatrixInjector.user, and EcalDBConnection.user.

286  def run(self, input):
287 
288  report = None
289  if self.options.check and not input['CheckForMask']['MaskPresent']:
290 
291  options = copy.deepcopy(self.options)
292  options.user = self.user
293 
294  if 'BaseDataset' in input:
295  options.name = input['BaseDataset']['Name']
296  else:
297  options.name = None
298 
299  check = IntegrityCheck(self.dataset,options)
300  check.test()
301  report = check.structured()
302  pub = PublishToFileSystem(check)
303  pub.publish(report)
304  elif input['CheckForMask']['MaskPresent']:
305  report = input['CheckForMask']['Report']
306 
307  return {'MaskPresent':report is not None,'Report':report}
308