|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
import FWCore.ParameterSet.Config as cms
import EventFilter.L1TXRawToDigi.util as util
from FWCore.ParameterSet.VarParsing import VarParsing
options = VarParsing()
options.register('runNumber', 0, VarParsing.multiplicity.singleton, VarParsing.varType.int, 'Run to analyze')
options.register('lumis', '1-max', VarParsing.multiplicity.singleton, VarParsing.varType.string, 'Lumis')
options.register('dataStream', '/ExpressPhysics/Run2015D-Express-v3/FEVT', VarParsing.multiplicity.singleton, VarParsing.varType.string, 'Dataset to look for run in')
options.register('inputFiles', [], VarParsing.multiplicity.list, VarParsing.varType.string, 'Manual file list input, will query DAS if empty')
options.register('inputFileList', '', VarParsing.multiplicity.singleton, VarParsing.varType.string, 'Manual file list input, will query DAS if empty')
options.register('useORCON', False, VarParsing.multiplicity.singleton, VarParsing.varType.bool, 'Use ORCON for conditions. This is necessary for very recent runs where conditions have not propogated to Frontier')
options.parseArguments()
def formatLumis(lumistring, run) :
lumis = (lrange.split('-') for lrange in lumistring.split(','))
runlumis = (['%d:%s' % (run,lumi) for lumi in lrange] for lrange in lumis)
return ['-'.join(l) for l in runlumis]
print('Getting files for run %d...' % options.runNumber)
if len(options.inputFiles) is 0 and options.inputFileList is '' :
inputFiles = util.getFilesForRun(options.runNumber, options.dataStream)
elif len(options.inputFileList) > 0 :
with open(options.inputFileList) as f :
inputFiles = list((line.strip() for line in f))
else :
inputFiles = cms.untracked.vstring(options.inputFiles)
if len(inputFiles) is 0 :
raise Exception('No files found for dataset %s run %d' % (options.dataStream, options.runNumber))
print('Ok, time to analyze')
process = cms.Process("L1TCaloLayer1Test")
process.load("FWCore.MessageService.MessageLogger_cfi")
process.load('EventFilter.L1TXRawToDigi.caloLayer1Stage2Digis_cfi')
process.maxEvents = cms.untracked.PSet( input = cms.untracked.int32(-1) )
process.source = cms.Source("PoolSource",
fileNames = cms.untracked.vstring(
inputFiles
),
# lumisToProcess = cms.untracked.VLuminosityBlockRange(formatLumis(options.lumis, options.runNumber))
)
process.out = cms.OutputModule("PoolOutputModule",
fileName = cms.untracked.string('/data/dasu/l1tCaloLayer1Digis.root'),
outputCommands = cms.untracked.vstring('drop *', 'keep *_*_*_L1TCaloLayer1Test')
)
process.load('Configuration/StandardSequences/FrontierConditions_GlobalTag_cff')
process.GlobalTag.globaltag = '74X_dataRun2_Express_v1'
process.p = cms.Path(process.l1tCaloLayer1Digis)
process.e = cms.EndPath(process.out)
|