Merge branch 'master-eventprintoutlvl' into 'master'

DerivationFrameworkConfiguration+RecJobTransforms: Set Loop Manager EventPrintoutInterval to 100 events in CA-based AODMerge and Derivations

See merge request atlas/athena!55613

Control/AthenaMP/src/AthMpEvtLoopMgr.cxx

@@ -55,6 +55,7 @@ AthMpEvtLoopMgr::AthMpEvtLoopMgr(const std::string& name
   , m_nPollingInterval(100) // 0.1 second
   , m_nMemSamplingInterval(0) // no sampling by default
   , m_nEventsBeforeFork(0)
+  , m_eventPrintoutInterval(1)
   , m_masterPid(getpid())
 {
   declareProperty("NWorkers",m_nWorkers);
@@ -67,6 +68,7 @@ AthMpEvtLoopMgr::AthMpEvtLoopMgr(const std::string& name
   declareProperty("PollingInterval",m_nPollingInterval);
   declareProperty("MemSamplingInterval",m_nMemSamplingInterval);
   declareProperty("EventsBeforeFork",m_nEventsBeforeFork);
+  declareProperty("EventPrintoutInterval",m_eventPrintoutInterval);
 }
 
 AthMpEvtLoopMgr::~AthMpEvtLoopMgr()
@@ -111,6 +113,17 @@ StatusCode AthMpEvtLoopMgr::initialize()
   }
 
   ATH_CHECK(m_evtProcessor.retrieve());
+  if(!m_isPileup) {
+    IProperty* propertyServer = dynamic_cast<IProperty*>(m_evtProcessor.get());
+    if(propertyServer) {
+      if(propertyServer->setProperty("EventPrintoutInterval",m_eventPrintoutInterval).isFailure()) {
+        ATH_MSG_WARNING("Could not set AthenaEventLoopMgr EventPrintoutInterval to " << m_eventPrintoutInterval);
+      }
+    }
+    else {
+      ATH_MSG_WARNING("Could not cast AthenaEventLoopMgr to IProperty");
+    }
+  }
   ATH_CHECK(m_tools.retrieve());
 
   return StatusCode::SUCCESS;

Control/AthenaMP/src/AthMpEvtLoopMgr.h

 /*
-  Copyright (C) 2002-2019 CERN for the benefit of the ATLAS collaboration
+  Copyright (C) 2002-2022 CERN for the benefit of the ATLAS collaboration
 */
 
 #ifndef ATHENAMP_ATHMPEVTLOOPMGR_H
@@ -49,6 +49,7 @@ class AthMpEvtLoopMgr
   int                            m_nPollingInterval;      // in milliseconds
   int                            m_nMemSamplingInterval;  // in seconds
   int                            m_nEventsBeforeFork;
+  unsigned int                   m_eventPrintoutInterval;
   pid_t                          m_masterPid;
 
   // vectors for collecting memory samples

PhysicsAnalysis/DerivationFramework/DerivationFrameworkConfiguration/python/DerivationSkeleton.py

@@ -93,6 +93,9 @@ def fromRunArgs(runArgs):
     from PerfMonComps.PerfMonCompsConfig import PerfMonMTSvcCfg
     cfg.merge(PerfMonMTSvcCfg(ConfigFlags))
 
+    # Set EventPrintoutInterval to 100 events
+    cfg.getService(cfg.getAppProps()["EventLoop"]).EventPrintoutInterval = 100
+
     # Post-include
     processPostInclude(runArgs, ConfigFlags, cfg)
 

Reconstruction/RecJobTransforms/python/AODMerge_Skeleton.py

@@ -80,8 +80,8 @@ def fromRunArgs(runArgs):
         from PerfMonComps.PerfMonCompsConfig import PerfMonMTSvcCfg
         cfg.merge(PerfMonMTSvcCfg(ConfigFlags))
 
-
-    cfg.getService("AthenaEventLoopMgr").EventPrintoutInterval = 100
+    # Set EventPrintoutInterval to 100 events
+    cfg.getService(cfg.getAppProps()["EventLoop"]).EventPrintoutInterval = 100
 
     # Post-include
     log.info('**** Processing postInclude')