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.OutputFileName', '')
310 flags.addFlag('Trigger.Online.EFInterface.LoopFiles', False)
311 flags.addFlag('Trigger.Online.EFInterface.NumEvents', -1)
312 flags.addFlag('Trigger.Online.EFInterface.SkipEvents', 0)
313 flags.addFlag('Trigger.Online.EFInterface.RunNumber', 0)
314 flags.addFlag('Trigger.Online.EFInterface.T0ProjectTag', '')
315 flags.addFlag('Trigger.Online.EFInterface.BeamType', 0)
316 flags.addFlag('Trigger.Online.EFInterface.BeamEnergy', 0)
317 flags.addFlag('Trigger.Online.EFInterface.TriggerType', 0)
318 flags.addFlag('Trigger.Online.EFInterface.Stream', '')
319 flags.addFlag('Trigger.Online.EFInterface.Lumiblock', 0)
320 flags.addFlag('Trigger.Online.EFInterface.DetMask', '00000000000000000000000000000000')
321 flags.addFlag('Trigger.Online.EFInterface.LibraryName', 'TrigDFEmulator',
322 help='Name of the EFDF interface shared library to load')
323
324 flags.addFlag('Trigger.Online.useOnlineTHistSvc', False,
325 help='use online THistSvc')
326
327 flags.addFlag('Trigger.Online.useOnlineWebdaqHistSvc', False,
328 help='use online Webdaq HistSvc')
329
330 flags.addFlag('Trigger.Online.BFieldAutoConfig', True,
331 help='auto-configure magnetic field from currents in IS')
332
333 flags.addFlag('Trigger.writeBS', False,
334 help='enable bytestream writing of trigger information')
335
336 flags.addFlag('Trigger.doTransientByteStream', lambda prevFlags:
337 True if prevFlags.Input.Format is Format.POOL and prevFlags.Trigger.doCalo else False,
338 help='create transient BS (for running on MC RDO with clients that require BS inputs)')
339
340 flags.addFlag('Trigger.AODEDMSet', lambda flags: 'AODSLIM' if flags.Input.isMC else 'AODFULL',
341 help='list of EDM objects to be written to AOD')
342
343 flags.addFlag('Trigger.ESDEDMSet', 'ESD',
344 help='list of EDM objects to be written to ESD')
345
346 flags.addFlag('Trigger.addRun3LowMuEDM', lambda prevFlags: "pp_lowMu_run3" in prevFlags.Trigger.triggerMenuSetup, help="Specify whether to add dedicated low mu EDM. Default is dependent on the menu setup." )
347
348 flags.addFlag('Trigger.ExtraEDMList', [],
349 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.')
350
351 def __availableRecoMetadata(flags):
352 systems = ['L1','HLT']
353
354 if not any(flags.Input.Files) and flags.Common.isOnline:
355 return systems
356
357 elif flags.Trigger.doHLT:
358 raise RuntimeError('Trigger.availableRecoMetadata is ill-defined if Trigger.doHLT==True')
359
360 elif flags.Input.Format is Format.BS:
361 from TrigConfigSvc.TriggerConfigAccess import getKeysFromConditions
362 keys = getKeysFromConditions(flags.Input.RunNumbers[0], lbNr = 1, flags = flags)
363 return ( (['L1'] if 'LVL1PSK' in keys else []) +
364 (['HLT'] if 'HLTPSK' in keys else []) )
365
366 else:
367 return systems if flags.Trigger.triggerConfig == 'INFILE' else []
368
369 flags.addFlag('Trigger.availableRecoMetadata', lambda flags: __availableRecoMetadata(flags),
370 help="list of enabled trigger sub-systems in reconstruction: ['L1,'HLT']")
371
372 flags.addFlag("Trigger.decodeHLT", True,
373 help='enable decoding of HLT trigger decision/result in reconstruction')
374
375 flags.addFlag("Trigger.DecisionMakerValidation.Execute", True,
376 help='run trigger decision validation algorithm in reconstruction')
377
378 flags.addFlag("Trigger.DecisionMakerValidation.ErrorMode", True,
379 help='emit an ERROR (or WARNING) in case of trigger decision validation failure')
380
381
382 def __triggerConfig(flags):
383 _log = logging.getLogger('TriggerConfigFlags.triggerConfig')
384 if flags.Common.isOnline and not flags.Trigger.doHLT:
385
386 _log.debug("Autoconfigured default value for running reconstruction inside Point 1: 'DB'")
387 return 'DB'
388 elif flags.Input.Format is Format.BS:
389 from glob import glob
390 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
391 if flags.Trigger.doHLT:
392
393 _log.debug("Autoconfigured default value for running the trigger on data: 'FILE'")
394 return 'FILE'
395 elif hasLocal:
396
397
398
399 _log.debug("Autoconfigured default value for running reconstruction with a pre-supplied set of trigger configuration JSON files: 'FILE'")
400 return 'FILE'
401 elif flags.GeoModel.Run >= LHCPeriod.Run3:
402
403 _log.debug("Autoconfigured default value for reconstruction of Run 3 data: 'DB'")
404 return 'DB'
405 else:
406
407 _log.debug("Autoconfigured default value for reconstruction of Run 1 or Run 2 data: 'FILE'")
408 return 'FILE'
409 else:
410 from AthenaConfiguration.AutoConfigFlags import GetFileMD
411 md = GetFileMD(flags.Input.Files)
412
413
414 hasTrigMeta = ("metadata_items" in md and any(('TriggerMenu' in key) for key in md["metadata_items"].keys()))
415 if hasTrigMeta:
416
417 _log.debug("Autoconfigured default value to read trigger configuration data from the input file: 'INFILE'")
418 return 'INFILE'
419 else:
420
421 _log.debug("Autoconfigured default value to read trigger configuration data from disk for MC production: 'FILE'")
422 return 'FILE'
423
424 flags.addFlag('Trigger.triggerConfig', lambda flags: __triggerConfig(flags),
425 help='Trigger configuration source (https://twiki.cern.ch/twiki/bin/view/Atlas/TriggerConfigFlag)')
426
427 flags.addFlag('Trigger.useCrest', lambda prevFlags: prevFlags.IOVDb.UseCREST,
428 help='Flag enables trigger configuration database access through CREST')
429
430 flags.addFlag('Trigger.crestServer', lambda prevFlags: prevFlags.IOVDb.CrestServer,
431 help='CREST server to access trigger configuration')
432
433 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',
434 help='name of the trigger menu')
435
436 flags.addFlag('Trigger.generateMenuDiagnostics', False,
437 help='print debug output from control flow generation')
438
439 flags.addFlag('Trigger.fastMenuGeneration', True,
440 help='avoid re-merging CAs that were already seen once')
441
442 flags.addFlag('Trigger.disableCPS', False,
443 help='disable coherent prescale sets (for testing with small menu)')
444
445 flags.addFlag('Trigger.enableEndOfEventProcessing', True,
446 help='enable execution of extra algorithms for accepted events')
447
448 flags.addFlag('Trigger.doCFEmulationTest', False,
449 help='enable run Control Flow Emulation test')
450
451
452
453
454 if doTriggerRecoFlags:
455 flags.join( createTriggerRecoFlags() )
456
457
458 flags.Trigger.disableCPS = lambda prevFlags: prevFlags.Trigger.selectChains or len(prevFlags.Trigger.enabledSignatures)==1
459
460 return flags
461
462