6
7 import logging
8 local_logger = logging.getLogger('AthenaMonitoringCfg')
9 info = local_logger.info
10 info('In CTPMonitoringConfig')
11
12 '''Function to call CTP DQ monitoring algorithms'''
13 from AthenaConfiguration.ComponentAccumulator import ComponentAccumulator
14 result = ComponentAccumulator()
15
16 if not flags.Input.isMC:
17 info('CTPMonitoringConfig: attempting to add DATA COOL folders')
18 from IOVDbSvc.IOVDbSvcConfig import addFolders
19 if not flags.Common.isOnline:
20 result.merge(addFolders(flags,'/LHC/DCS/FILLSTATE','DCS_OFL',className='CondAttrListCollection'))
21
22 result.merge(addFolders(flags,'/TDAQ/RunCtrl/DataTakingMode','TDAQ',className='AthenaAttributeList'))
23 info('CTPMonitoringConfig: added DATA COOL folders')
24
25
26 if flags.DQ.Environment in ('online', 'tier0', 'tier0Raw'):
27
28 from TriggerJobOpts.TriggerByteStreamConfig import ByteStreamReadCfg
29 result.merge(ByteStreamReadCfg(flags, [
30 "MuCTPI_RDO/MUCTPI_RDO",
31 "CTP_RDO/CTP_RDO",
32
33 "CTP_RIO/CTP_RIO"
34 ]))
35 info('In CTPMonitoringConfig added ByteStreamReadCfg MUCTPI_RDO,CTP_RDO,CTP_RIO' )
36
37
38 if not flags.Trigger.Online.isPartition:
39 if not flags.DQ.triggerDataAvailable:
40 return result
41
42
43
44
45
46
47
49
50
51
52 if flags.DQ.Environment not in ( 'AOD', 'DAOD_PHYS', 'tier0ESD'):
54 result.merge(BSMonitoringConfig(flags))
55 info('CTPMonitoringConfig: requested: result.merge(BSMonitoringConfig(flags))')
56 info('after results_merge CTPMonitoringConfig')
57 return result
58