33def createTriggerFlags(doTriggerRecoFlags):
34 flags = AthConfigFlags()
35
36 flags.addFlag('Trigger.doLVL1', lambda prevFlags: prevFlags.Input.isMC,
37 help='enable L1 simulation')
38
39 flags.addFlag('Trigger.doHLT', False,
40 help='run HLT selection algorithms')
41
42 flags.addFlag("Trigger.forceEnableAllChains", lambda prevFlags: prevFlags.GeoModel.Run >= LHCPeriod.Run4,
43 help='always enable all configured chains (for testing). Currently enabled by default for Run 4.')
44
45 flags.addFlag("Trigger.disableL1ConsistencyChecker", False,
46 help='force disabling the L1 ConsistencyChecker')
47
48 flags.addFlag('Trigger.enableL0Muon',
49 lambda prevFlags: prevFlags.GeoModel.Run >= LHCPeriod.Run4,
50 help='enable Run-4+ L0 Muon simulation or decoding')
51
52 flags.addFlag('Trigger.enableL1MuonPhase1', lambda prevFlags:
53 (not prevFlags.Trigger.enableL0Muon) and
54 prevFlags.Trigger.EDMVersion >= 3 or prevFlags.Detector.EnableMM or prevFlags.Detector.EnablesTGC,
55 help='enable Run-3 LVL1 muon decoding')
56
57 flags.addFlag('Trigger.enableL1CaloPhase1', lambda prevFlags:
58 prevFlags.Trigger.EDMVersion >= 3 or prevFlags.GeoModel.Run >= LHCPeriod.Run3,
59 help='enable Phase-1 LVL1 calo simulation and/or decoding for Run-3+')
60
61 flags.addFlag('Trigger.enableL1TopoDump', False,
62 help='enable L1Topo simulation to write inputs to txt file')
63
64 flags.addFlag('Trigger.enableL1TopoBWSimulation', True,
65 help='enable bitwise L1Topo simulation')
66
67 flags.addFlag('Trigger.enableL1CaloLegacy', lambda prevFlags:
68 not (not prevFlags.Input.isMC and prevFlags.Trigger.doHLT),
69 help='enable Run-2 L1Calo simulation and/or decoding')
70
71
72 flags.addFlag('Trigger.L0MuonSim.doEmulation',
73 lambda prevFlags: prevFlags.Trigger.enableL0Muon and
74 prevFlags.Input.isMC and
75 'TruthParticleContainer' in prevFlags.Input.Collections,
76 help='Emulate the L0Muon trigger TOBs from smeared truth muon particles')
77
78
79 flags.addFlag('Trigger.L1MuonSim.EmulateNSW', False,
80 help='enable emulation tool for NSW-TGC coincidence')
81
82 flags.addFlag('Trigger.L1MuonSim.doMMTrigger', True,
83 help='enable NSW MM trigger')
84
85 flags.addFlag('Trigger.L1MuonSim.doPadTrigger', True,
86 help='enable NSW sTGC pad trigger')
87
88 flags.addFlag('Trigger.L1MuonSim.doStripTrigger', False,
89 help='enable NSW sTGC strip trigger')
90
91 flags.addFlag('Trigger.L1MuonSim.WriteNSWDebugNtuple', False,
92 help='enable Storing NSW debug Ntuple')
93
94 flags.addFlag('Trigger.L1MuonSim.WriteMMBranches', False,
95 help='enable storing of Micromega branches in NSW debug Ntuple')
96
97 flags.addFlag('Trigger.L1MuonSim.WritesTGCBranches', False,
98 help='enable storing of TGC branches in NSW debug Ntuple')
99
100 flags.addFlag('Trigger.L1MuonSim.NSWVetoMode', True,
101 help='enable the veto mode of the NSW-TGC coincidence')
102
103 flags.addFlag('Trigger.L1MuonSim.doBIS78', True,
104 help='enable TGC-RPC BIS78 coincidence')
105
106 flags.addFlag('Trigger.L1MuonSim.CondDBOffline', 'OFLCOND-MC16-SDR-RUN2-04',
107 help='offline CondDB tag for RPC/TGC coincidence window in rerunLVL1 on data')
108
109 flags.addFlag('Trigger.L1MuonSim.RPCNBX', lambda prevFlags:
110 8 if prevFlags.Input.isMC else 4,
111 help='Number of bunch crossings in RPC readout')
112
113 flags.addFlag('Trigger.L1MuonSim.RPCNBCZ', lambda prevFlags:
114 3 if prevFlags.Input.isMC else 1,
115 help='Nominal BC for RPC readout')
116
117
118
119 flags.addFlag('Trigger.doID', True,
120 help='enable Inner Detector')
121
122 flags.addFlag('Trigger.doMuon', True,
123 help='enable muon systems')
124
125 flags.addFlag('Trigger.doCalo', True,
126 help='enable calorimeters')
127
128 flags.addFlag('Trigger.doZDC', False,
129 help='enable ZDC system')
130
131 flags.addFlag('Trigger.ZdcLUT', 'TrigT1ZDC/zdcRun3T1LUT_v2_08_08_2023.json',
132 help='path to Run3 ZDC LUT')
133
134
135 flags.addFlag('Trigger.doTRT', False)
136
137
138 flags.addFlag('Trigger.TRT.TTCMultiplicity', 4)
139
140
141 flags.addFlag('Trigger.TRT.maskedChipsFile', 'TrigT1TRT/fastORmaskedChips.json')
142
143
144 flags.addFlag('Trigger.doValidationMonitoring', False,
145 help='enable additional validation histograms')
146
147 flags.addFlag('Trigger.doRuntimeNaviVal', False,
148 help=('Check validity of each Decision objects in the entire decision tree (CPU expensive). '
149 'Also enable per-step decision printouts.'))
150
151 flags.addFlag('Trigger.ROBPrefetchingOptions',
152 [ROBPrefetching.InitialRoI, ROBPrefetching.StepRoI, ROBPrefetching.TauCoreLargeRoI],
153 help='select ROB prefetching types, empty list disables prefetching')
154
155 def EDMVersion(flags):
156 """Determine Trigger EDM version based on the input file."""
157 _log = logging.getLogger('TriggerConfigFlags.EDMVersion')
158
159 default_version = -1
160
161 if flags.Input.Format is Format.BS:
162 _log.debug("Input format is ByteStream")
163
164 if not any(flags.Input.Files) and flags.Common.isOnline:
165 _log.info("Online reconstruction, no input file. Return default EDMVersion=%d", default_version)
166 return default_version
167 try:
168 from TrigEDMConfig.Utils import getEDMVersionFromBS
169 except ImportError:
170 log.error("Failed to import TrigEDMConfig, analysing ByteStream files is not possible in this release!")
171 raise
172
173
174 version = getEDMVersionFromBS(flags.Input.Files[0])
175
176 return version if version is not None else default_version
177
178 else:
179
180 _log.debug("Input format is POOL -- determine from input file collections")
181 collections = flags.Input.Collections
182 if "HLTResult_EF" in collections:
183 _log.info("Determined EDMVersion to be 1, because HLTResult_EF found in POOL file")
184 return 1
185 elif "TrigNavigation" in collections:
186 _log.info("Determined EDMVersion to be 2, because TrigNavigation found in POOL file")
187 return 2
188 elif flags.Trigger.doHLT:
189 if flags.GeoModel.Run >= LHCPeriod.Run4:
190 _log.info("Determined EDMVersion to be 4, because we're now running the trigger and GeoModel.Run >= 4")
191 return 4
192 else:
193 _log.info("Determined EDMVersion to be 3, because we're now running the trigger")
194 return 3
195 elif any("HLTNav_Summary" in s for s in collections):
196 if flags.GeoModel.Run >= LHCPeriod.Run4:
197 _log.info("Determined EDMVersion to be 4, because HLTNav_Summary.* found in POOL file and GeoModel.Run >= 4")
198 return 4
199 else:
200 _log.info("Determined EDMVersion to be 3, because HLTNav_Summary.* found in POOL file")
201 return 3
202 elif not flags.Input.Collections:
203
204
205 _log.warning("All input files seem to be empty, cannot determine EDM version. Guessing EDMVersion=3")
206 return 3
207
208 _log.info("Could not determine EDM version from the input file. Return default EDMVersion=%d",
209 default_version)
210 return default_version
211
212 flags.addFlag('Trigger.EDMVersion', lambda prevFlags: EDMVersion(prevFlags),
213 help='Trigger EDM version (determined by input file or set to the version to be produced)')
214
215 flags.addFlag('Trigger.doEDMVersionConversion', False,
216 help='convert Run-1&2 EDM to Run-3 EDM')
217
218 flags.addFlag('Trigger.doxAODConversion', True,
219 help=('convert Run-1 EDM to xAOD'))
220
221 flags.addFlag('Trigger.doOnlineNavigationCompactification', True,
222 help='enable trigger Navigation compactification into a single collection')
223
224 flags.addFlag('Trigger.doNavigationSlimming', True,
225 help='enable Navigation slimming for RAWtoXYZ or AODtoDAOD transforms')
226
227 flags.addFlag('Trigger.derivationsExtraChains', [],
228 help='list of chains which should be considered for trigger-matching in addition to those from the TriggerAPI when running derivations')
229
230
231 flags.addFlag('Trigger.CostMonitoring.doCostMonitoring', True,
232 help='enable cost monitoring')
233
234 flags.addFlag('Trigger.CostMonitoring.chain', 'HLT_noalg_CostMonDS_L1All',
235 help='Cost monitoring chain name')
236
237 flags.addFlag('Trigger.CostMonitoring.outputCollection', 'HLT_TrigCostContainer',
238 help='Cost monitoring output collection name')
239
240 flags.addFlag('Trigger.CostMonitoring.monitorAllEvents', False,
241 help='enable Cost monitoring for all events')
242
243 flags.addFlag('Trigger.CostMonitoring.monitorROBs', True,
244 help='enable Cost monitoring of ROB accesses')
245
246
247 flags.addFlag('Trigger.L1.doMuon', True,
248 help='enable L1Muon ByteStream conversion/simulation')
249
250 flags.addFlag('Trigger.L1.doMuonTopoInputs', True,
251 help='enable ByteStream conversion/simulation of MUCTPI Topo TOBs')
252
253 flags.addFlag('Trigger.L1.doCalo', True,
254 help='enable L1Calo ByteStream conversion/simulation')
255
256 flags.addFlag('Trigger.L1.doCaloInputs', lambda prevFlags:
257 prevFlags.Trigger.L1.doCalo and prevFlags.Trigger.enableL1CaloPhase1 and not prevFlags.Trigger.doHLT,
258 help='enable L1Calo Input ([ejg]Towers) ByteStream conversion/simulation')
259
260 flags.addFlag('Trigger.L1.doeFex', lambda prevFlags:
261 prevFlags.Trigger.L1.doCalo and prevFlags.Trigger.enableL1CaloPhase1,
262 help='enable eFEX ByteStream conversion/simulation')
263
264 flags.addFlag('Trigger.L1.Menu.doeFexBDTTau', True,
265 help='set BDT tau algorithm as the active one for eFEX when constructing L1 menus')
266
267 flags.addFlag('Trigger.L1.dojFex', lambda prevFlags:
268 prevFlags.Trigger.L1.doCalo and prevFlags.Trigger.enableL1CaloPhase1,
269 help='enable jFEX ByteStream conversion/simulation')
270
271 flags.addFlag('Trigger.L1.dogFex', lambda prevFlags:
272 prevFlags.Trigger.L1.doCalo and prevFlags.Trigger.enableL1CaloPhase1,
273 help='enable gFEX ByteStream conversion/simulation')
274
275 flags.addFlag('Trigger.L1.L1CaloSuperCellContainerName', lambda prevFlags:
276 "EmulatedSCell" if prevFlags.GeoModel.Run is LHCPeriod.Run2 else "SCell",
277 help='name of SuperCell container')
278
279 flags.addFlag('Trigger.L1.doTopo', True,
280 help='enable L1Topo ByteStream conversion/simulation (steering both legacy and phase-1 Topo)')
281
282 flags.addFlag('Trigger.L1.doTopoPhase1', lambda prevFlags:
283 prevFlags.Trigger.L1.doTopo and prevFlags.Trigger.enableL1CaloPhase1,
284 help='control Phase-I L1Topo simulation even if L1.doTopo is True')
285
286 flags.addFlag('Trigger.L1.doGlobal', lambda prevFlags: prevFlags.GeoModel.Run >= LHCPeriod.Run4,
287 help='enable L0Global ByteStream conversion/simulation')
288
289 flags.addFlag('Trigger.L1.doCTP', True,
290 help='enable CTP ByteStream conversion/simulation')
291
292 flags.addFlag('Trigger.L1.Menu.doHeavyIonTobThresholds', lambda prevFlags:
293 'HI' in prevFlags.Trigger.triggerMenuSetup,
294 help='modify min-pt-to-Topo threshold for TOBs to HI values')
295
296 flags.addFlag('Trigger.L1.errorOnMissingTOB', True,
297 help='Set to true to enable strict-mode which will generate an ERROR on missing (non-overflow) TOB events in HLT-seeding from L1')
298
299
300 flags.addFlag('Trigger.Online.partitionName', os.getenv('TDAQ_PARTITION') or '',
301 help='partition name used to determine online vs offline BS result writing')
302
303 flags.addFlag('Trigger.Online.isPartition', lambda prevFlags: len(prevFlags.Trigger.Online.partitionName)>0,
304 help='check if job is running in a partition (i.e. partition name is not empty)')
305
306 flags.addFlag("Trigger.Online.useEFByteStreamSvc", False,
307 help='use online EF ByteStream services')
308 flags.addFlag('Trigger.Online.EFInterface.Files', [])
309 flags.addFlag('Trigger.Online.EFInterface.LoopFiles', False)
310 flags.addFlag('Trigger.Online.EFInterface.NumEvents', -1)
311 flags.addFlag('Trigger.Online.EFInterface.SkipEvents', 0)
312 flags.addFlag('Trigger.Online.EFInterface.RunNumber', 0)
313
314 flags.addFlag('Trigger.Online.useOnlineTHistSvc', False,
315 help='use online THistSvc')
316
317 flags.addFlag('Trigger.Online.useOnlineWebdaqHistSvc', False,
318 help='use online Webdaq HistSvc')
319
320 flags.addFlag('Trigger.Online.BFieldAutoConfig', True,
321 help='auto-configure magnetic field from currents in IS')
322
323 flags.addFlag('Trigger.writeBS', False,
324 help='enable bytestream writing of trigger information')
325
326 flags.addFlag('Trigger.doTransientByteStream', lambda prevFlags:
327 True if prevFlags.Input.Format is Format.POOL and prevFlags.Trigger.doCalo else False,
328 help='create transient BS (for running on MC RDO with clients that require BS inputs)')
329
330 flags.addFlag('Trigger.AODEDMSet', lambda flags: 'AODSLIM' if flags.Input.isMC else 'AODFULL',
331 help='list of EDM objects to be written to AOD')
332
333 flags.addFlag('Trigger.ESDEDMSet', 'ESD',
334 help='list of EDM objects to be written to ESD')
335
336 flags.addFlag('Trigger.ExtraEDMList', [],
337 help='list of extra EDM objects to be stored (for testing). Supported features: Add new items. Add extra decorations to existing Aux. Add additional output targets.')
338
339 def __availableRecoMetadata(flags):
340 systems = ['L1','HLT']
341
342 if not any(flags.Input.Files) and flags.Common.isOnline:
343 return systems
344
345 elif flags.Trigger.doHLT:
346 raise RuntimeError('Trigger.availableRecoMetadata is ill-defined if Trigger.doHLT==True')
347
348 elif flags.Input.Format is Format.BS:
349 from TrigConfigSvc.TriggerConfigAccess import getKeysFromConditions
350 keys = getKeysFromConditions(flags.Input.RunNumbers[0], lbNr = 1, flags = flags)
351 return ( (['L1'] if 'LVL1PSK' in keys else []) +
352 (['HLT'] if 'HLTPSK' in keys else []) )
353
354 else:
355 return systems if flags.Trigger.triggerConfig == 'INFILE' else []
356
357 flags.addFlag('Trigger.availableRecoMetadata', lambda flags: __availableRecoMetadata(flags),
358 help="list of enabled trigger sub-systems in reconstruction: ['L1,'HLT']")
359
360 flags.addFlag("Trigger.decodeHLT", True,
361 help='enable decoding of HLT trigger decision/result in reconstruction')
362
363 flags.addFlag("Trigger.DecisionMakerValidation.Execute", True,
364 help='run trigger decision validation algorithm in reconstruction')
365
366 flags.addFlag("Trigger.DecisionMakerValidation.ErrorMode", True,
367 help='emit an ERROR (or WARNING) in case of trigger decision validation failure')
368
369
370 def __triggerConfig(flags):
371 _log = logging.getLogger('TriggerConfigFlags.triggerConfig')
372 if flags.Common.isOnline and not flags.Trigger.doHLT:
373
374 _log.debug("Autoconfigured default value for running reconstruction inside Point 1: 'DB'")
375 return 'DB'
376 elif flags.Input.Format is Format.BS:
377 from glob import glob
378 hasLocal = True if (glob("HLTMenu*.json") and glob("L1Menu*.json") and glob("HLTPrescales*.json") and glob("L1Prescales*.json") and glob("HLTMonitoring*.json") and glob("BunchGroupSet*.json")) else False
379 if flags.Trigger.doHLT:
380
381 _log.debug("Autoconfigured default value for running the trigger on data: 'FILE'")
382 return 'FILE'
383 elif hasLocal:
384
385
386
387 _log.debug("Autoconfigured default value for running reconstruction with a pre-supplied set of trigger configuration JSON files: 'FILE'")
388 return 'FILE'
389 elif flags.GeoModel.Run >= LHCPeriod.Run3:
390
391 _log.debug("Autoconfigured default value for reconstruction of Run 3 data: 'DB'")
392 return 'DB'
393 else:
394
395 _log.debug("Autoconfigured default value for reconstruction of Run 1 or Run 2 data: 'FILE'")
396 return 'FILE'
397 else:
398 from AthenaConfiguration.AutoConfigFlags import GetFileMD
399 md = GetFileMD(flags.Input.Files)
400
401
402 hasTrigMeta = ("metadata_items" in md and any(('TriggerMenu' in key) for key in md["metadata_items"].keys()))
403 if hasTrigMeta:
404
405 _log.debug("Autoconfigured default value to read trigger configuration data from the input file: 'INFILE'")
406 return 'INFILE'
407 else:
408
409 _log.debug("Autoconfigured default value to read trigger configuration data from disk for MC production: 'FILE'")
410 return 'FILE'
411
412 flags.addFlag('Trigger.triggerConfig', lambda flags: __triggerConfig(flags),
413 help='Trigger configuration source (https://twiki.cern.ch/twiki/bin/view/Atlas/TriggerConfigFlag)')
414
415 flags.addFlag('Trigger.useCrest', lambda prevFlags: prevFlags.IOVDb.UseCREST,
416 help='Flag enables trigger configuration database access through CREST')
417
418 flags.addFlag('Trigger.crestServer', lambda prevFlags: prevFlags.IOVDb.CrestServer,
419 help='CREST server to access trigger configuration')
420
421 flags.addFlag('Trigger.triggerMenuSetup', lambda flags: 'MC_pp_run3_v1_BulkMCProd_prescale' if flags.GeoModel.Run is LHCPeriod.Run3 else 'MC_pp_run4_v1_BulkMCProd_prescale',
422 help='name of the trigger menu')
423
424 flags.addFlag('Trigger.generateMenuDiagnostics', False,
425 help='print debug output from control flow generation')
426
427 flags.addFlag('Trigger.fastMenuGeneration', True,
428 help='avoid re-merging CAs that were already seen once')
429
430 flags.addFlag('Trigger.disableCPS', False,
431 help='disable coherent prescale sets (for testing with small menu)')
432
433 flags.addFlag('Trigger.enableEndOfEventProcessing', True,
434 help='enable execution of extra algorithms for accepted events')
435
436 flags.addFlag('Trigger.doCFEmulationTest', False,
437 help='enable run Control Flow Emulation test')
438
439
440
441
442 if doTriggerRecoFlags:
443 flags.join( createTriggerRecoFlags() )
444
445
446 flags.Trigger.disableCPS = lambda prevFlags: prevFlags.Trigger.selectChains or len(prevFlags.Trigger.enabledSignatures)==1
447
448 return flags
449
450