Reference Manual

Inheritance diagram for production_tasks.FullCFG:

Public Member Functions
def	__init__

def	addOption

def	run

Public Member Functions inherited from production_tasks.Task
def	__init__

def	addOption

def	getname

def	run

Additional Inherited Members
Public Attributes inherited from production_tasks.Task
	dataset

	instance

	name

	options

	user

Detailed Description

Generate the full CFG needed to run the job and writes it to the job directory

Definition at line 378 of file production_tasks.py.

Constructor & Destructor Documentation

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

Definition at line 380 of file production_tasks.py.

380

381 def __init__(self, dataset, user, options):

Task.__init__(self,'FullCFG', dataset, user, options)

production_tasks.FullCFG.__init__

def __init__

Definition: production_tasks.py:380

def production_tasks.FullCFG.run	(	self,
		input
	)

Definition at line 385 of file production_tasks.py.

References CalibratedPatElectronProducer.dataset, production_tasks.Task.dataset, CalibratedElectronProducer.dataset, edmIntegrityCheck.IntegrityCheck.dataset, genericValidation.GenericValidationData.dataset, mergeVDriftHistosByStation.file, production_tasks.insertLines(), dataset.BaseDataset.user, EcalTPGParamReaderFromDB.user, production_tasks.Task.user, popcon::RPCObPVSSmapData.user, popcon::RpcDataT.user, popcon::RpcDataV.user, popcon::RpcObGasData.user, popcon::RpcDataFebmap.user, popcon::RpcDataGasMix.user, popcon::RpcDataUXC.user, popcon::RpcDataS.user, popcon::RpcDataI.user, MatrixInjector.MatrixInjector.user, EcalDBConnection.user, and conddblib.TimeType.user.

 
     def run(self, input):
         
         jobdir = input['CreateJobDirectory']['JobDir']
 
         if self.options.cfg is None or not os.path.exists(self.options.cfg):
             raise Exception("The file '%s' does not exist. Please check." % self.options.cfg)
         
         config = file(self.options.cfg).readlines()
         sourceFile = os.path.basename(input['SourceCFG']['SourceCFG'])
         if sourceFile.lower().endswith('.py'):
             sourceFile = sourceFile[:-3]
         
         source = os.path.join(jobdir,'full_cfg.py')
         output = file(source,'w')
 
         nEventsPerJob = -1
         if self.options.nEventsPerJob:
             nEventsPerJob = int(self.options.nEventsPerJob)
         
         toInsert = ['\nfrom %s import *\n' % sourceFile,
                     'process.source.fileNames = files\n',
                     'if hasattr(process,"maxEvents"): process.maxEvents.input = cms.untracked.int32({nEvents})\n'.format(nEvents=nEventsPerJob),
                     'if hasattr(process,"maxLuminosityBlocks"): process.maxLuminosityBlocks.input = cms.untracked.int32(-1)\n'
                     'datasetInfo = ("%s","%s","%s")\n' % (self.user, self.dataset, fnmatch.translate(self.options.wildcard) )
                     ]
         config = insertLines( config, toInsert )
         output.writelines(config)
         output.close()
         return {'FullCFG':source}