10def HGTD_OverlayAlgCfg(flags, name="HGTD_Overlay", **kwargs):
11 """Return a ComponentAccumulator for HGTD overlay algorithm"""
12 acc = ComponentAccumulator()
13
14 kwargs.setdefault("BkgInputKey", f"{flags.Overlay.BkgPrefix}HGTD_RDOs")
15 kwargs.setdefault("SignalInputKey", f"{flags.Overlay.SigPrefix}HGTD_RDOs")
16 kwargs.setdefault("OutputKey", "HGTD_RDOs")
17
18 if flags.Overlay.ByteStream:
19 pass
20 else:
21 from SGComps.SGInputLoaderConfig import SGInputLoaderCfg
22 acc.merge(SGInputLoaderCfg(flags, [f'HGTD_RDO_Container#{kwargs["BkgInputKey"]}']))
23
24
25 acc.addEventAlgo(CompFactory.HGTD_Overlay(name, **kwargs))
26
27
28 if flags.Output.doWriteRDO:
29 from OutputStreamAthenaPool.OutputStreamConfig import OutputStreamCfg
30 acc.merge(OutputStreamCfg(flags, "RDO", ItemList=[
31 "HGTD_RDO_Container#HGTD_RDOs"
32 ]))
33
34 if flags.Output.doWriteRDO_SGNL:
35 from OutputStreamAthenaPool.OutputStreamConfig import OutputStreamCfg
36 acc.merge(OutputStreamCfg(flags, "RDO_SGNL", ItemList=[
37 f"HGTD_RDO_Container#{flags.Overlay.SigPrefix}HGTD_RDOs"
38 ]))
39
40 return acc
41
42