Skip to content

Commit 9a90756

Browse files
committed
use consumeWhenAll completion policy in ccdb-populator
1 parent 4679fed commit 9a90756

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

Detectors/Calibration/workflow/ccdb-populator-workflow.cxx

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
#include "CCDBPopulatorSpec.h"
1414
#include "CommonUtils/ConfigurableParam.h"
1515
#include "CommonUtils/NameConf.h"
16+
#include <regex>
1617

1718
using namespace o2::framework;
1819

@@ -33,7 +34,10 @@ void customize(std::vector<o2::framework::CompletionPolicy>& policies)
3334
// we customize the pipeline processors to consume data as it comes
3435
using CompletionPolicy = o2::framework::CompletionPolicy;
3536
using CompletionPolicyHelpers = o2::framework::CompletionPolicyHelpers;
36-
auto& pol = policies.emplace_back(CompletionPolicyHelpers::defineByName("ccdb-populator.*", CompletionPolicy::CompletionOp::Consume));
37+
auto matcher = [](o2::framework::DeviceSpec const& device) -> bool {
38+
return std::regex_match(device.name.begin(), device.name.end(), std::regex("ccdb-populator.*"));
39+
};
40+
auto& pol = policies.emplace_back(CompletionPolicyHelpers::consumeWhenAll("ccdb-populator-consume-all", matcher));
3741
pol.order = CompletionPolicy::CompletionOrder::Slot;
3842
}
3943

0 commit comments

Comments
 (0)