Public Member Functions | |
def | __init__ |
def | dqmOutputDir |
def | run |
def | runAnalysisResiduals |
def | runAnalysisWorkflow |
Analysis workflow. More... | |
def | runDBValidationWorkflow |
DB Validation workflow. More... | |
def | runDQMClient |
def | runDQMHarvesting |
def | runDQMMerge |
def | runNoiseWorkflow |
noise workflow More... | |
def | runResidualCalib |
def | runT0Workflow |
t0 workflow More... | |
def | runTtrigProd |
def | runTtrigResidualCorr |
def | runTtrigValid |
def | runTtrigValidSummary |
def | runTtrigWorkflow |
tTrig workflow More... | |
def | runTtrigWriter |
def | runValidationWorkflow |
Validation workflow. More... | |
def | runVDriftMeanTimerCalib |
def | runVDriftMeanTimerWriter |
def | runVDriftSegmentCalib |
def | runVDriftSegmentWriter |
def | runVDriftWorkflow |
vDrift workflow More... | |
Public Attributes | |
config | |
refRun | |
Static Public Attributes | |
string | castor_dir = config.castorpath+"/" |
string | crab_output_dir = project_noise+"/res" |
string | crab_task_dir = config.base_dir+'/' |
tuple | crabAnalysisResiduals = CrabWatch(project_analysisResiduals) |
tuple | crabdir = findLastWorkDir('crab_0_') |
tuple | crabNoiseCalibration = CrabWatch(project_noise) |
tuple | crabProd = CrabWatch(project_prod) |
tuple | crabResidualCalib = CrabWatch(project_residualCalib) |
tuple | crabValid = CrabWatch(project_valid) |
tuple | crabVDriftMeanTimer = CrabWatch(project_meantimer) |
tuple | crabVDriftSegment = CrabWatch(project_segment) |
tuple | cwd = os.getcwd() |
tuple | datasetstr = getDatasetStr(config.datasetpath) |
string | dirLabel = 'DQM' |
list | dqm_files = [] |
tuple | dqm_files = listFilesLocal(output_dir,'DQM') |
tuple | dqm_merge_dir = os.path.abspath(result_dir) |
string | dqm_output_dir = '' |
tuple | dqm_output_dir = self.dqmOutputDir('TTrigValidation','ResidualsResidCorr',config) |
tuple | dtAnalysisResiduals |
dtDBValidation = None | |
tuple | dtDBValidation |
tuple | dtDqmFinal = DTDqm(run,config.run_dir,dqm_files,config.result_dir,config) |
tuple | dtDQMMerge = DTDQMMerge(run,config.run_dir,dqm_files,config.result_dir,config) |
tuple | dtDQMValid |
tuple | dtNoiseCalibration |
tuple | dtResidualCalib |
tuple | dtTtrigProd = DTTTrigProd(run,task_dir,config) |
tuple | dtTtrigResidualCorr |
tuple | dtTtrigValid |
tuple | dtTtrigValidSummary = DTValidSummary(run,config.run_dir,input_file,output_file,config) |
tuple | dtTtrigWriter = DTTTrigTimeBoxesWriter(run,config.run_dir,config.result_dir,config) |
tuple | dtVDriftMeanTimer |
tuple | dtVDriftMeanTimerWriter |
tuple | dtVDriftSegment |
tuple | dtVDriftSegmentWriter |
list | inputFiles = [] |
tuple | noise_db = os.path.abspath(result_dir + '/' + 'noise_' + run + '.db') |
tuple | noise_txt = os.path.abspath(result_dir + '/' + 'noise_' + run + '.txt') |
string | output_dir = project_prod+"/res" |
tuple | project_analysisResiduals = dtAnalysisResiduals.run() |
tuple | project_meantimer = dtVDriftMeanTimer.run() |
tuple | project_noise = dtNoiseCalibration.run() |
tuple | project_prod = dtTtrigProd.run() |
tuple | project_residualCalib = dtResidualCalib.run() |
tuple | project_segment = dtVDriftSegment.run() |
tuple | project_valid = dtTtrigValid.run() |
tuple | residualsFile = os.path.abspath(result_dir + '/' + 'DTResiduals_' + run + '.root') |
tuple | residualsFirst = os.path.abspath(result_dir + '/' + 'DTResidualValidation_' + run + '.root') |
tuple | residualsResidCorr = os.path.abspath(result_dir + '/' + 'DTResidualValidation_ResidCorr_' + run + '.root') |
tuple | residualsValid = os.path.abspath(result_dir + '/' + 'DTResidualValidation_' + run + '.root') |
result_dir = config.result_dir | |
string | result_file = config.result_dir+'/DTTimeBoxes_%s.root' |
tuple | result_file = os.path.abspath(result_dir + '/' + 'dtNoiseCalib_' + run + '.root') |
tuple | retcode = copyFilesLocal(crab_output_dir,result_dir,'dtNoiseCalib') |
runselection = config.runselection | |
tuple | summaryResiduals = os.path.abspath(result_dir + '/' + 'SummaryResiduals_' + run + '.root') |
string | task_dir = config.base_dir+'/TimeBoxes' |
tuple | timeBoxes = os.path.abspath(result_dir + '/' + 'DTTimeBoxes_' + run + '.root') |
trial = config.trial | |
ttrig_input_db = None | |
tuple | ttrig_residuals_db = os.path.abspath(result_dir + '/' + 'ttrig_residuals_' + run + '.db') |
tuple | ttrig_timeboxes_db = os.path.abspath(result_dir + '/' + 'ttrig_timeboxes_' + run + '.db') |
tuple | vDrift_meantimer_db = os.path.abspath(result_dir + '/' + 'vDrift_meantimer_' + run + '.db') |
tuple | vDrift_segment_db = os.path.abspath(result_dir + '/' + 'vDrift_segment_' + run + '.db') |
tuple | vDriftHistos = os.path.abspath(result_dir + '/' + 'DTVDriftHistos_' + run + '.root') |
tuple | vDriftTMaxHistos = os.path.abspath(result_dir + '/' + 'DTTMaxHistos_' + run + '.root') |
Definition at line 22 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.__init__ | ( | self, | |
run, | |||
config | |||
) |
Definition at line 23 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.dqmOutputDir | ( | self, | |
type, | |||
dirLabel, | |||
config | |||
) |
Definition at line 46 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.run | ( | self, | |
type, | |||
mode, | |||
execute | |||
) |
Definition at line 27 of file DTCalibrationWorker.py.
References DTAnalysisResiduals.DTAnalysisResiduals.config, preexistingValidation.PreexistingValidation.config, genericValidation.GenericValidation.config, DTCalibrationWorker.DTCalibrationWorker.config, DTCalibrationWorker.DTCalibrationWorker.refRun, DTCalibrationWorker.DTCalibrationWorker.runAnalysisWorkflow(), DTCalibrationWorker.DTCalibrationWorker.runNoiseWorkflow(), DTCalibrationWorker.DTCalibrationWorker.runT0Workflow(), DTCalibrationWorker.DTCalibrationWorker.runTtrigWorkflow(), DTCalibrationWorker.DTCalibrationWorker.runValidationWorkflow(), and DTCalibrationWorker.DTCalibrationWorker.runVDriftWorkflow().
Referenced by Types.EventID.cppID(), and Types.LuminosityBlockID.cppID().
def DTCalibrationWorker.DTCalibrationWorker.runAnalysisResiduals | ( | self, | |
run, | |||
runselection, | |||
trial, | |||
label, | |||
result_file, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 145 of file DTCalibrationWorker.py.
References tools.getDatasetStr().
def DTCalibrationWorker.DTCalibrationWorker.runAnalysisWorkflow | ( | self, | |
mode, | |||
run, | |||
config, | |||
execute = True |
|||
) |
Analysis workflow.
Definition at line 713 of file DTCalibrationWorker.py.
Referenced by DTCalibrationWorker.DTCalibrationWorker.run().
def DTCalibrationWorker.DTCalibrationWorker.runDBValidationWorkflow | ( | self, | |
mode, | |||
run, | |||
inputFiles, | |||
config, | |||
execute = True |
|||
) |
DB Validation workflow.
Definition at line 737 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runDQMClient | ( | self, | |
run, | |||
output_dir, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 347 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runDQMHarvesting | ( | self, | |
run, | |||
output_dir, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 372 of file DTCalibrationWorker.py.
References tools.listFilesInCastor(), and tools.listFilesLocal().
def DTCalibrationWorker.DTCalibrationWorker.runDQMMerge | ( | self, | |
run, | |||
output_dir, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 397 of file DTCalibrationWorker.py.
References tools.listFilesLocal().
def DTCalibrationWorker.DTCalibrationWorker.runNoiseWorkflow | ( | self, | |
mode, | |||
run, | |||
config, | |||
execute = True |
|||
) |
noise workflow
Definition at line 616 of file DTCalibrationWorker.py.
Referenced by DTCalibrationWorker.DTCalibrationWorker.run().
def DTCalibrationWorker.DTCalibrationWorker.runResidualCalib | ( | self, | |
run, | |||
runselection, | |||
trial, | |||
input_db, | |||
label, | |||
result_file, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 109 of file DTCalibrationWorker.py.
References tools.getDatasetStr().
def DTCalibrationWorker.DTCalibrationWorker.runT0Workflow | ( | self, | |
mode, | |||
run, | |||
config, | |||
execute = True |
|||
) |
t0 workflow
Definition at line 663 of file DTCalibrationWorker.py.
Referenced by DTCalibrationWorker.DTCalibrationWorker.run().
def DTCalibrationWorker.DTCalibrationWorker.runTtrigProd | ( | self, | |
run, | |||
runselection, | |||
trial, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 63 of file DTCalibrationWorker.py.
References tools.getDatasetStr().
def DTCalibrationWorker.DTCalibrationWorker.runTtrigResidualCorr | ( | self, | |
run, | |||
input_db, | |||
root_file, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 179 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runTtrigValid | ( | self, | |
run, | |||
runselection, | |||
trial, | |||
input_db, | |||
label, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 196 of file DTCalibrationWorker.py.
References tools.getDatasetStr().
def DTCalibrationWorker.DTCalibrationWorker.runTtrigValidSummary | ( | self, | |
run, | |||
input_file, | |||
output_file, | |||
config, | |||
runStep = True |
|||
) |
if config.stageOutLocal: output_dir = project_valid + "/res" haddLocal(output_dir,result_file,'residuals') elif config.stageOutCAF: castor_dir = config.castorpath + "/" + config.userdircaf haddInCastor(castor_dir,result_file,'residuals','rfio://castorcms/','?svcClass=cmscafuser')
Definition at line 234 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runTtrigWorkflow | ( | self, | |
mode, | |||
run, | |||
config, | |||
execute = True |
|||
) |
tTrig workflow
Definition at line 425 of file DTCalibrationWorker.py.
Referenced by DTCalibrationWorker.DTCalibrationWorker.run().
Definition at line 97 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runValidationWorkflow | ( | self, | |
mode, | |||
run, | |||
config, | |||
execute = True |
|||
) |
Validation workflow.
Definition at line 670 of file DTCalibrationWorker.py.
References tools.getDatasetStr().
Referenced by DTCalibrationWorker.DTCalibrationWorker.run().
def DTCalibrationWorker.DTCalibrationWorker.runVDriftMeanTimerCalib | ( | self, | |
run, | |||
runselection, | |||
trial, | |||
label, | |||
result_file, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 296 of file DTCalibrationWorker.py.
References tools.getDatasetStr().
def DTCalibrationWorker.DTCalibrationWorker.runVDriftMeanTimerWriter | ( | self, | |
run, | |||
root_file, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 331 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runVDriftSegmentCalib | ( | self, | |
run, | |||
runselection, | |||
trial, | |||
label, | |||
result_file, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 245 of file DTCalibrationWorker.py.
References tools.getDatasetStr().
def DTCalibrationWorker.DTCalibrationWorker.runVDriftSegmentWriter | ( | self, | |
run, | |||
root_file, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 280 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runVDriftWorkflow | ( | self, | |
mode, | |||
run, | |||
config, | |||
execute = True |
|||
) |
vDrift workflow
Definition at line 567 of file DTCalibrationWorker.py.
Referenced by DTCalibrationWorker.DTCalibrationWorker.run().
|
static |
Definition at line 90 of file DTCalibrationWorker.py.
DTCalibrationWorker.DTCalibrationWorker.config |
Definition at line 24 of file DTCalibrationWorker.py.
Referenced by DTNoiseCalibration.DTNoiseCalibration.initCrab(), DTTTrigProd.DTTTrigProd.initCrab(), DTDQMValidation.DTDQMValidation.initCrab(), DTResidualCalibration.DTResidualCalibration.initCrab(), DTTTrigValid.DTTTrigValid.initCrab(), DTVDriftMeanTimerCalibration.DTVDriftMeanTimerCalibration.initCrab(), DTVDriftSegmentCalibration.DTVDriftSegmentCalibration.initCrab(), DTT0DBValidation.DTT0DBValidation.initProcess(), DTDQMMerge.DTDQMMerge.initProcess(), DTDqm.DTDqm.initProcess(), DTDQMHarvesting.DTDQMHarvesting.initProcess(), DTVDriftMeanTimerCalibration.DTVDriftMeanTimerCalibration.initProcess(), DTTTrigProd.DTTTrigProd.initProcess(), DTVDriftSegmentCalibration.DTVDriftSegmentCalibration.initProcess(), DTNoiseCalibration.DTNoiseCalibration.initProcess(), DTResidualCalibration.DTResidualCalibration.initProcess(), DTDQMValidation.DTDQMValidation.initProcess(), DTTTrigValid.DTTTrigValid.initProcess(), and DTCalibrationWorker.DTCalibrationWorker.run().
|
static |
Definition at line 650 of file DTCalibrationWorker.py.
|
static |
Definition at line 51 of file DTCalibrationWorker.py.
|
static |
Definition at line 163 of file DTCalibrationWorker.py.
|
static |
Definition at line 53 of file DTCalibrationWorker.py.
|
static |
Definition at line 644 of file DTCalibrationWorker.py.
|
static |
Definition at line 80 of file DTCalibrationWorker.py.
|
static |
Definition at line 129 of file DTCalibrationWorker.py.
|
static |
Definition at line 216 of file DTCalibrationWorker.py.
|
static |
Definition at line 315 of file DTCalibrationWorker.py.
|
static |
Definition at line 264 of file DTCalibrationWorker.py.
|
static |
Definition at line 50 of file DTCalibrationWorker.py.
|
static |
Definition at line 58 of file DTCalibrationWorker.py.
|
static |
Definition at line 676 of file DTCalibrationWorker.py.
|
static |
Definition at line 352 of file DTCalibrationWorker.py.
Referenced by DTDqm.DTDqm.initProcess(), and DTDQMMerge.DTDQMMerge.initProcess().
|
static |
Definition at line 354 of file DTCalibrationWorker.py.
Referenced by DTDqm.DTDqm.initProcess(), and DTDQMMerge.DTDQMMerge.initProcess().
|
static |
Definition at line 705 of file DTCalibrationWorker.py.
|
static |
# Summary of validation if not os.path.exists(summaryResiduals): self.runTtrigValidSummary(run,residualsResidCorr,summaryResiduals,config) if not os.path.exists(summaryResiduals): raise RuntimeError,'Could not produce %s' % summaryResiduals
# Summary of validation if not os.path.exists(summaryResiduals): self.runTtrigValidSummary(run,residualsValid,summaryResiduals,config) if not os.path.exists(summaryResiduals): raise RuntimeError,'Could not produce %s' % summaryResiduals
Definition at line 47 of file DTCalibrationWorker.py.
|
static |
# Summary of validation if not os.path.exists(summaryResiduals): self.runTtrigValidSummary(run,residualsResidCorr,summaryResiduals,config) if not os.path.exists(summaryResiduals): raise RuntimeError,'Could not produce %s' % summaryResiduals
# Summary of validation if not os.path.exists(summaryResiduals): self.runTtrigValidSummary(run,residualsValid,summaryResiduals,config) if not os.path.exists(summaryResiduals): raise RuntimeError,'Could not produce %s' % summaryResiduals
Definition at line 477 of file DTCalibrationWorker.py.
|
static |
Definition at line 152 of file DTCalibrationWorker.py.
|
static |
Definition at line 740 of file DTCalibrationWorker.py.
|
static |
Definition at line 742 of file DTCalibrationWorker.py.
|
static |
Definition at line 356 of file DTCalibrationWorker.py.
|
static |
Definition at line 406 of file DTCalibrationWorker.py.
|
static |
Definition at line 680 of file DTCalibrationWorker.py.
|
static |
Definition at line 631 of file DTCalibrationWorker.py.
|
static |
Definition at line 117 of file DTCalibrationWorker.py.
Definition at line 71 of file DTCalibrationWorker.py.
|
static |
Definition at line 182 of file DTCalibrationWorker.py.
|
static |
Definition at line 204 of file DTCalibrationWorker.py.
|
static |
Definition at line 237 of file DTCalibrationWorker.py.
|
static |
Definition at line 100 of file DTCalibrationWorker.py.
|
static |
Definition at line 304 of file DTCalibrationWorker.py.
|
static |
Definition at line 334 of file DTCalibrationWorker.py.
|
static |
Definition at line 253 of file DTCalibrationWorker.py.
|
static |
Definition at line 283 of file DTCalibrationWorker.py.
|
static |
Definition at line 40 of file DTCalibrationWorker.py.
Referenced by VarParsing.VarParsing.parseArguments().
|
static |
Definition at line 623 of file DTCalibrationWorker.py.
|
static |
Definition at line 624 of file DTCalibrationWorker.py.
|
static |
Definition at line 87 of file DTCalibrationWorker.py.
Referenced by DTVDriftMeanTimerWriter.DTVDriftMeanTimerWriter.initProcess(), and DTVDriftSegmentWriter.DTVDriftSegmentWriter.initProcess().
|
static |
Definition at line 158 of file DTCalibrationWorker.py.
|
static |
Definition at line 310 of file DTCalibrationWorker.py.
|
static |
Definition at line 639 of file DTCalibrationWorker.py.
|
static |
Definition at line 75 of file DTCalibrationWorker.py.
|
static |
Definition at line 124 of file DTCalibrationWorker.py.
|
static |
Definition at line 259 of file DTCalibrationWorker.py.
|
static |
Definition at line 211 of file DTCalibrationWorker.py.
DTCalibrationWorker.DTCalibrationWorker.refRun |
Definition at line 25 of file DTCalibrationWorker.py.
Referenced by DTCalibrationWorker.DTCalibrationWorker.run().
|
static |
Definition at line 719 of file DTCalibrationWorker.py.
|
static |
Definition at line 434 of file DTCalibrationWorker.py.
|
static |
Definition at line 436 of file DTCalibrationWorker.py.
|
static |
Definition at line 530 of file DTCalibrationWorker.py.
|
static |
Definition at line 430 of file DTCalibrationWorker.py.
Referenced by DTDqm.DTDqm.initProcess(), DTDQMMerge.DTDQMMerge.initProcess(), DTTTrigResidualCorr.DTTTrigResidualCorr.initProcess(), DTTTrigCorrFirst.DTTTrigCorrFirst.initProcess(), and DTTTrigTimeBoxesWriter.DTTTrigTimeBoxesWriter.initProcess().
|
static |
Definition at line 85 of file DTCalibrationWorker.py.
|
static |
Definition at line 622 of file DTCalibrationWorker.py.
|
static |
Definition at line 651 of file DTCalibrationWorker.py.
|
static |
Definition at line 427 of file DTCalibrationWorker.py.
|
static |
Definition at line 437 of file DTCalibrationWorker.py.
|
static |
Definition at line 70 of file DTCalibrationWorker.py.
|
static |
Definition at line 432 of file DTCalibrationWorker.py.
|
static |
Definition at line 426 of file DTCalibrationWorker.py.
|
static |
Definition at line 428 of file DTCalibrationWorker.py.
|
static |
Definition at line 435 of file DTCalibrationWorker.py.
|
static |
Definition at line 433 of file DTCalibrationWorker.py.
|
static |
Definition at line 593 of file DTCalibrationWorker.py.
|
static |
Definition at line 573 of file DTCalibrationWorker.py.
|
static |
Definition at line 572 of file DTCalibrationWorker.py.
|
static |
Definition at line 592 of file DTCalibrationWorker.py.