From 9a9075672e2fe64a618ab23b59e489ebdfd1fa74 Mon Sep 17 00:00:00 2001 From: Ernst Hellbar Date: Thu, 13 Aug 2026 09:12:11 +0200 Subject: [PATCH] use consumeWhenAll completion policy in ccdb-populator --- Detectors/Calibration/workflow/ccdb-populator-workflow.cxx | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/Detectors/Calibration/workflow/ccdb-populator-workflow.cxx b/Detectors/Calibration/workflow/ccdb-populator-workflow.cxx index d03920b7a657f..209b3a35aa45e 100644 --- a/Detectors/Calibration/workflow/ccdb-populator-workflow.cxx +++ b/Detectors/Calibration/workflow/ccdb-populator-workflow.cxx @@ -13,6 +13,7 @@ #include "CCDBPopulatorSpec.h" #include "CommonUtils/ConfigurableParam.h" #include "CommonUtils/NameConf.h" +#include using namespace o2::framework; @@ -33,7 +34,10 @@ void customize(std::vector& policies) // we customize the pipeline processors to consume data as it comes using CompletionPolicy = o2::framework::CompletionPolicy; using CompletionPolicyHelpers = o2::framework::CompletionPolicyHelpers; - auto& pol = policies.emplace_back(CompletionPolicyHelpers::defineByName("ccdb-populator.*", CompletionPolicy::CompletionOp::Consume)); + auto matcher = [](o2::framework::DeviceSpec const& device) -> bool { + return std::regex_match(device.name.begin(), device.name.end(), std::regex("ccdb-populator.*")); + }; + auto& pol = policies.emplace_back(CompletionPolicyHelpers::consumeWhenAll("ccdb-populator-consume-all", matcher)); pol.order = CompletionPolicy::CompletionOrder::Slot; }