From 19450406562a6882e7f8a250135e762ac61d03af Mon Sep 17 00:00:00 2001 From: Giulio Eulisse <10544+ktf@users.noreply.github.com> Date: Thu, 17 Apr 2025 16:57:31 +0200 Subject: [PATCH] Saner publishing period for FLP case --- Framework/Core/src/CommonServices.cxx | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/Framework/Core/src/CommonServices.cxx b/Framework/Core/src/CommonServices.cxx index 5c333bbb85e3b..22324cd84b390 100644 --- a/Framework/Core/src/CommonServices.cxx +++ b/Framework/Core/src/CommonServices.cxx @@ -891,6 +891,11 @@ o2::framework::ServiceSpec CommonServices::dataProcessingStats() if (!DefaultsHelpers::onlineDeploymentMode() && DefaultsHelpers::deploymentMode() != DeploymentMode::FST) { arrowAndResourceLimitingMetrics = true; } + + int64_t consumedTimeframesPublishInterval = 0; + if (DefaultsHelpers::deploymentMode() == DeploymentMode::OnlineECS) { + consumedTimeframesPublishInterval = 5000; + } // Input proxies should not report cpu_usage_fraction, // because of the rate limiting which biases the measurement. auto& spec = services.get(); @@ -950,7 +955,7 @@ o2::framework::ServiceSpec CommonServices::dataProcessingStats() MetricSpec{.name = "consumed-timeframes", .metricId = (int)ProcessingStatsId::CONSUMED_TIMEFRAMES, .kind = Kind::UInt64, - .minPublishInterval = 0, + .minPublishInterval = consumedTimeframesPublishInterval, .maxRefreshLatency = quickRefreshInterval, .sendInitialValue = true}, MetricSpec{.name = "min_input_latency_ms",