Run the 'cmsBatch.py' command on your CFG, submitting to the CERN batch system
Definition at line 524 of file production_tasks.py.
def production_tasks.RunCMSBatch.run |
( |
|
self, |
|
|
|
input |
|
) |
| |
Definition at line 539 of file production_tasks.py.
References production_tasks.Task.dataset, edmIntegrityCheck.IntegrityCheck.dataset, genericValidation.GenericValidationData.dataset, join(), FileExportPlugin.FileExportPlugin.options, cmsswPreprocessor.CmsswPreprocessor.options, DTCalibrationWorker.DTCalibrationWorker.options, DTWorkflow.DTWorkflow.options, TestProcess.TestProcess.options, DOTExport.DotProducer.options, confdb.HLTProcess.options, production_tasks.Task.options, edmIntegrityCheck.IntegrityCheck.options, validateAlignments.ValidationJobMultiIOV.options, edm.print(), and str.
544 full = input[
'ExpandConfig'][
'ExpandedFullCFG']
545 jobdir = input[
'CreateJobDirectory'][
'JobDir']
547 sampleDir = os.path.join(out[
'Directory'],self.options.tier)
548 sampleDir = castortools.castorToLFN(sampleDir)
550 cmd = [
'cmsBatch.py',
str(self.options.nInput),os.path.basename(full),
'-o',
'%s_Jobs' % self.options.tier,
'--force']
551 cmd.extend([
'-r',sampleDir])
552 if self.options.run_batch:
553 jname =
"%s/%s" % (self.
dataset,self.options.tier)
554 jname = jname.replace(
"//",
"/")
556 if self.options.group
is not None:
557 user_group =
'-G %s' % self.options.group
558 cmd.extend([
'-b',
"'bsub -q %s -J %s -u cmgtoolslsf@gmail.com %s < ./batchScript.sh | tee job_id.txt'" % (self.options.queue,jname,user_group)])
566 returncode = os.system(
" ".
join(cmd))
569 error =
"Running cmsBatch failed. Return code was %i." % returncode
573 if error
is not None:
576 return {
'SampleDataset':
"%s/%s" % (self.
dataset,self.options.tier),
'BatchUser':self.options.batch_user,
577 'SampleOutputDir':sampleDir,
'LSFJobsTopDir':os.path.join(jobdir,
'%s_Jobs' % self.options.tier)}
S & print(S &os, JobReport::InputFile const &f)
static std::string join(char **cmd)