Public Member Functions | |
def | __init__ |
def | dqmOutputDir |
def | run |
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 | 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) |
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_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 | 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 21 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.__init__ | ( | self, | |
run, | |||
config | |||
) |
Definition at line 22 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.dqmOutputDir | ( | self, | |
type, | |||
dirLabel, | |||
config | |||
) |
Definition at line 44 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.run | ( | self, | |
type, | |||
mode, | |||
execute | |||
) |
Definition at line 26 of file DTCalibrationWorker.py.
References genericValidation.GenericValidation.config, DTCalibrationWorker.DTCalibrationWorker.config, DTCalibrationWorker.DTCalibrationWorker.refRun, DTCalibrationWorker.DTCalibrationWorker.runNoiseWorkflow(), DTCalibrationWorker.DTCalibrationWorker.runT0Workflow(), DTCalibrationWorker.DTCalibrationWorker.runTtrigWorkflow(), DTCalibrationWorker.DTCalibrationWorker.runValidationWorkflow(), and DTCalibrationWorker.DTCalibrationWorker.runVDriftWorkflow().
Referenced by Types.LuminosityBlockID.cppID().
def DTCalibrationWorker.DTCalibrationWorker.runDBValidationWorkflow | ( | self, | |
mode, | |||
run, | |||
inputFiles, | |||
config, | |||
execute = True |
|||
) |
DB Validation workflow.
Definition at line 675 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runDQMClient | ( | self, | |
run, | |||
output_dir, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 311 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runDQMHarvesting | ( | self, | |
run, | |||
output_dir, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 336 of file DTCalibrationWorker.py.
References tools.listFilesInCastor(), and tools.listFilesLocal().
def DTCalibrationWorker.DTCalibrationWorker.runDQMMerge | ( | self, | |
run, | |||
output_dir, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 361 of file DTCalibrationWorker.py.
References tools.listFilesLocal().
def DTCalibrationWorker.DTCalibrationWorker.runNoiseWorkflow | ( | self, | |
mode, | |||
run, | |||
config, | |||
execute = True |
|||
) |
noise workflow
Definition at line 579 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 107 of file DTCalibrationWorker.py.
References tools.getDatasetStr().
def DTCalibrationWorker.DTCalibrationWorker.runT0Workflow | ( | self, | |
mode, | |||
run, | |||
config, | |||
execute = True |
|||
) |
t0 workflow
Definition at line 625 of file DTCalibrationWorker.py.
Referenced by DTCalibrationWorker.DTCalibrationWorker.run().
def DTCalibrationWorker.DTCalibrationWorker.runTtrigProd | ( | self, | |
run, | |||
runselection, | |||
trial, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 61 of file DTCalibrationWorker.py.
References tools.getDatasetStr().
def DTCalibrationWorker.DTCalibrationWorker.runTtrigResidualCorr | ( | self, | |
run, | |||
input_db, | |||
root_file, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 143 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runTtrigValid | ( | self, | |
run, | |||
runselection, | |||
trial, | |||
input_db, | |||
label, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 160 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 198 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runTtrigWorkflow | ( | self, | |
mode, | |||
run, | |||
config, | |||
execute = True |
|||
) |
tTrig workflow
Definition at line 389 of file DTCalibrationWorker.py.
Referenced by DTCalibrationWorker.DTCalibrationWorker.run().
Definition at line 95 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runValidationWorkflow | ( | self, | |
mode, | |||
run, | |||
config, | |||
execute = True |
|||
) |
Validation workflow.
Definition at line 632 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 260 of file DTCalibrationWorker.py.
References tools.getDatasetStr().
def DTCalibrationWorker.DTCalibrationWorker.runVDriftMeanTimerWriter | ( | self, | |
run, | |||
root_file, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 295 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runVDriftSegmentCalib | ( | self, | |
run, | |||
runselection, | |||
trial, | |||
label, | |||
result_file, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 209 of file DTCalibrationWorker.py.
References tools.getDatasetStr().
def DTCalibrationWorker.DTCalibrationWorker.runVDriftSegmentWriter | ( | self, | |
run, | |||
root_file, | |||
config, | |||
runStep = True |
|||
) |
Definition at line 244 of file DTCalibrationWorker.py.
def DTCalibrationWorker.DTCalibrationWorker.runVDriftWorkflow | ( | self, | |
mode, | |||
run, | |||
config, | |||
execute = True |
|||
) |
vDrift workflow
Definition at line 530 of file DTCalibrationWorker.py.
Referenced by DTCalibrationWorker.DTCalibrationWorker.run().
|
static |
Definition at line 88 of file DTCalibrationWorker.py.
DTCalibrationWorker.DTCalibrationWorker.config |
Definition at line 23 of file DTCalibrationWorker.py.
Referenced by DTNoiseCalibration.DTNoiseCalibration.initCrab(), DTTTrigProd.DTTTrigProd.initCrab(), DTDQMValidation.DTDQMValidation.initCrab(), DTResidualCalibration.DTResidualCalibration.initCrab(), DTVDriftMeanTimerCalibration.DTVDriftMeanTimerCalibration.initCrab(), DTVDriftSegmentCalibration.DTVDriftSegmentCalibration.initCrab(), DTTTrigValid.DTTTrigValid.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 612 of file DTCalibrationWorker.py.
|
static |
Definition at line 49 of file DTCalibrationWorker.py.
|
static |
Definition at line 51 of file DTCalibrationWorker.py.
|
static |
Definition at line 606 of file DTCalibrationWorker.py.
|
static |
Definition at line 78 of file DTCalibrationWorker.py.
|
static |
Definition at line 127 of file DTCalibrationWorker.py.
|
static |
Definition at line 180 of file DTCalibrationWorker.py.
|
static |
Definition at line 279 of file DTCalibrationWorker.py.
|
static |
Definition at line 228 of file DTCalibrationWorker.py.
|
static |
Definition at line 48 of file DTCalibrationWorker.py.
|
static |
Definition at line 56 of file DTCalibrationWorker.py.
|
static |
Definition at line 638 of file DTCalibrationWorker.py.
|
static |
Definition at line 316 of file DTCalibrationWorker.py.
Referenced by DTDqm.DTDqm.initProcess(), and DTDQMMerge.DTDQMMerge.initProcess().
|
static |
Definition at line 318 of file DTCalibrationWorker.py.
Referenced by DTDqm.DTDqm.initProcess(), and DTDQMMerge.DTDQMMerge.initProcess().
|
static |
Definition at line 667 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 45 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 441 of file DTCalibrationWorker.py.
|
static |
Definition at line 678 of file DTCalibrationWorker.py.
|
static |
Definition at line 680 of file DTCalibrationWorker.py.
|
static |
Definition at line 320 of file DTCalibrationWorker.py.
|
static |
Definition at line 370 of file DTCalibrationWorker.py.
|
static |
Definition at line 642 of file DTCalibrationWorker.py.
|
static |
Definition at line 593 of file DTCalibrationWorker.py.
|
static |
Definition at line 115 of file DTCalibrationWorker.py.
Definition at line 69 of file DTCalibrationWorker.py.
|
static |
Definition at line 146 of file DTCalibrationWorker.py.
|
static |
Definition at line 168 of file DTCalibrationWorker.py.
|
static |
Definition at line 201 of file DTCalibrationWorker.py.
|
static |
Definition at line 98 of file DTCalibrationWorker.py.
|
static |
Definition at line 268 of file DTCalibrationWorker.py.
|
static |
Definition at line 298 of file DTCalibrationWorker.py.
|
static |
Definition at line 217 of file DTCalibrationWorker.py.
|
static |
Definition at line 247 of file DTCalibrationWorker.py.
|
static |
Definition at line 38 of file DTCalibrationWorker.py.
Referenced by VarParsing.VarParsing.parseArguments().
|
static |
Definition at line 586 of file DTCalibrationWorker.py.
|
static |
Definition at line 587 of file DTCalibrationWorker.py.
|
static |
Definition at line 85 of file DTCalibrationWorker.py.
Referenced by DTVDriftMeanTimerWriter.DTVDriftMeanTimerWriter.initProcess(), and DTVDriftSegmentWriter.DTVDriftSegmentWriter.initProcess().
|
static |
Definition at line 274 of file DTCalibrationWorker.py.
|
static |
Definition at line 601 of file DTCalibrationWorker.py.
|
static |
Definition at line 73 of file DTCalibrationWorker.py.
|
static |
Definition at line 122 of file DTCalibrationWorker.py.
|
static |
Definition at line 223 of file DTCalibrationWorker.py.
|
static |
Definition at line 175 of file DTCalibrationWorker.py.
DTCalibrationWorker.DTCalibrationWorker.refRun |
Definition at line 24 of file DTCalibrationWorker.py.
Referenced by DTCalibrationWorker.DTCalibrationWorker.run().
|
static |
Definition at line 398 of file DTCalibrationWorker.py.
|
static |
Definition at line 400 of file DTCalibrationWorker.py.
|
static |
Definition at line 493 of file DTCalibrationWorker.py.
|
static |
Definition at line 394 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 83 of file DTCalibrationWorker.py.
|
static |
Definition at line 585 of file DTCalibrationWorker.py.
|
static |
Definition at line 613 of file DTCalibrationWorker.py.
|
static |
Definition at line 391 of file DTCalibrationWorker.py.
|
static |
Definition at line 401 of file DTCalibrationWorker.py.
|
static |
Definition at line 68 of file DTCalibrationWorker.py.
|
static |
Definition at line 396 of file DTCalibrationWorker.py.
|
static |
Definition at line 390 of file DTCalibrationWorker.py.
|
static |
Definition at line 392 of file DTCalibrationWorker.py.
|
static |
Definition at line 399 of file DTCalibrationWorker.py.
|
static |
Definition at line 397 of file DTCalibrationWorker.py.
|
static |
Definition at line 556 of file DTCalibrationWorker.py.
|
static |
Definition at line 536 of file DTCalibrationWorker.py.
|
static |
Definition at line 535 of file DTCalibrationWorker.py.
|
static |
Definition at line 555 of file DTCalibrationWorker.py.