|
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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
import FWCore.ParameterSet.Config as cms
import FWCore.ParameterSet.VarParsing as VarParsing
parser = VarParsing.VarParsing('python')
one = VarParsing.VarParsing.multiplicity.singleton
bool = VarParsing.VarParsing.varType.bool
string = VarParsing.VarParsing.varType.string
parser.register('nolegacy', False, one, bool, "Don't run legacy harvesters")
parser.register('nomodules', False, one, bool, "Don't run any harvesters")
parser.register('legacyoutput', False, one, bool, "Use DQMFileSaver for output instead of DQMIO.")
parser.register('protobufinput', False, one, bool, "Use DQMProtobufReader for input instead of DQMIO.")
parser.register('metoedminput', False, one, bool, "Use PoolInputSource and EDMtoMEConverter for input.")
parser.register('outfile', "dqm.root", one, string, "Output file name.")
parser.register('reScope', "", one, string, "Type of reScoping to use.")
parser.parseArguments()
args = parser
process = cms.Process("HARVESTING")
process.add_(cms.Service("DQMStore"))
process.load("DQMServices.Demo.testharvester_cfi")
process.load("DQMServices.Demo.testlegacyharvester_cfi")
print(args.inputFiles)
if args.protobufinput:
infile = args.inputFiles[0]
runnr = int(infile[-6:])
indir = "/".join(infile.split("/")[:-1])
process.source = cms.Source("DQMProtobufReader",
runNumber = cms.untracked.uint32(runnr),
runInputDir = cms.untracked.string(indir),
streamLabel = cms.untracked.string("streamDQMHistograms"),
scanOnce = cms.untracked.bool(True),
datafnPosition = cms.untracked.uint32(4),
delayMillis = cms.untracked.uint32(500),
nextLumiTimeoutMillis = cms.untracked.int32(-1),
skipFirstLumis = cms.untracked.bool(False),
deleteDatFiles = cms.untracked.bool(False),
endOfRunKills = cms.untracked.bool(False),
)
elif args.metoedminput:
process.EDMtoMEConverter = cms.EDProducer("EDMtoMEConverter",
Name = cms.untracked.string('EDMtoMEConverter'),
Verbosity = cms.untracked.int32(0),
Frequency = cms.untracked.int32(50),
convertOnEndLumi = cms.untracked.bool(True),
convertOnEndRun = cms.untracked.bool(True),
runInputTag = cms.InputTag('MEtoEDMConverter', 'MEtoEDMConverterRun'),
lumiInputTag = cms.InputTag('MEtoEDMConverter', 'MEtoEDMConverterLumi')
)
process.convert = cms.Path(process.EDMtoMEConverter)
process.source = cms.Source("PoolSource",
fileNames = cms.untracked.vstring(*["file://" + f for f in args.inputFiles]))
else:
process.source = cms.Source("DQMRootSource",
fileNames = cms.untracked.vstring(*["file://" + f for f in args.inputFiles]),
reScope = cms.untracked.string(args.reScope))
process.harvest = cms.Sequence(process.testharvester)
process.harvestlegacy = cms.Sequence(process.testlegacyharvester)
if args.nomodules:
pass
elif args.nolegacy:
process.p = cms.Path(process.harvest)
else:
process.p = cms.Path(process.harvest + process.harvestlegacy)
# legacy output
process.dqmSaver = cms.EDAnalyzer("DQMFileSaver",
convention = cms.untracked.string('Offline'),
fileFormat = cms.untracked.string('ROOT'),
producer = cms.untracked.string('DQM'),
workflow = cms.untracked.string('/Harvesting/DQMTests/DQMIO'),
dirName = cms.untracked.string('.'),
saveByRun = cms.untracked.int32(-1),
saveAtJobEnd = cms.untracked.bool(True),
)
# dqmio ouptut
process.out = cms.OutputModule("DQMRootOutputModule",
fileName = cms.untracked.string(args.outfile))
if args.legacyoutput:
process.e = cms.EndPath(process.dqmSaver)
else:
process.e = cms.EndPath(process.out)
# useful for debugging
#process.DQMStore.trackME = cms.untracked.string("testlegacyfillrun")
#process.Tracer = cms.Service("Tracer")
|