Skip to content

Commit 4f1b642

Browse files
committed
DPL: do not add outputs
1 parent 704ca25 commit 4f1b642

2 files changed

Lines changed: 9 additions & 2 deletions

File tree

Framework/Core/src/WorkflowHelpers.cxx

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -313,8 +313,10 @@ void WorkflowHelpers::injectServiceDevices(WorkflowSpec& workflow, ConfigContext
313313
// A timeframeSink consumes timeframes without creating new
314314
// timeframe data.
315315
bool timeframeSink = hasTimeframeInputs && !hasTimeframeOutputs;
316-
if (timeframeSink && processor.name != "internal-dpl-injected-dummy-sink") {
317-
processor.outputs.push_back(OutputSpec{{"dpl-summary"}, ConcreteDataMatcher{"DPL", "SUMMARY", static_cast<DataAllocator::SubSpecificationType>(compile_time_hash(processor.name.c_str()))}});
316+
if (std::stoi(ctx.options().get<std::string>("timeframes-rate-limit-ipcid")) != -1) {
317+
if (timeframeSink && processor.name != "internal-dpl-injected-dummy-sink") {
318+
processor.outputs.push_back(OutputSpec{{"dpl-summary"}, ConcreteDataMatcher{"DPL", "SUMMARY", static_cast<DataAllocator::SubSpecificationType>(compile_time_hash(processor.name.c_str()))}});
319+
}
318320
}
319321
bool hasConditionOption = false;
320322
for (size_t ii = 0; ii < processor.inputs.size(); ++ii) {

Framework/Core/test/Mocking.h

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,11 @@ std::unique_ptr<o2::framework::ConfigContext> makeEmptyConfigContext()
2323
// either owns or shares ownership of the registry.
2424
std::vector<std::unique_ptr<ParamRetriever>> retrievers;
2525
static std::vector<ConfigParamSpec> specs = WorkflowCustomizationHelpers::requiredWorkflowOptions();
26+
for (auto& spec : specs) {
27+
if (spec.name == "timeframes-rate-limit-ipcid") {
28+
spec.defaultValue = "1";
29+
}
30+
}
2631
auto store = std::make_unique<ConfigParamStore>(specs, std::move(retrievers));
2732
store->preload();
2833
store->activate();

0 commit comments

Comments
 (0)