Skip to content

Commit b264fad

Browse files
authored
Merge branch 'dev' into dynamic-extraction-matchers
2 parents d2f616b + 231abca commit b264fad

1 file changed

Lines changed: 15 additions & 0 deletions

File tree

Framework/Core/include/Framework/AnalysisTask.h

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
#include "Framework/AlgorithmSpec.h"
1717
#include "Framework/CallbackService.h"
1818
#include "Framework/ConfigContext.h"
19+
#include "Framework/ConfigParamsHelper.h"
1920
#include "Framework/ControlService.h"
2021
#include "Framework/DataProcessorSpec.h"
2122
#include "Framework/Expressions.h"
@@ -560,10 +561,24 @@ DataProcessorSpec adaptAnalysisTask(ConfigContext const& ctx, Args&&... args)
560561
LOG(warn) << "Task " << name_str << " has no inputs";
561562
}
562563

564+
<<<<<<< dynamic-extraction-matchers
563565
// update OutputSpecs in output declarations
564566
homogeneous_apply_refs_sized<numElements>([&newOrigin](auto& element) { return analysis_task_parsers::updateOutputSpec(element, newOrigin); }, *task.get());
565567

566568
// append outputs
569+
=======
570+
// Auto-register default ccdb: path options from subscribed timestamped-table inputs.
571+
// This allows tasks to accept --ccdb:fXxx overrides without requiring an explicit
572+
// ConfigurableCCDBPath<> member for every column in the subscribed table.
573+
for (auto& input : inputs) {
574+
for (auto& meta : input.metadata) {
575+
if (meta.name.starts_with("ccdb:") && meta.name != "ccdb:") {
576+
ConfigParamsHelper::addOptionIfMissing(options, meta);
577+
}
578+
}
579+
}
580+
581+
>>>>>>> dev
567582
homogeneous_apply_refs_sized<numElements>([&outputs, &hash](auto& element) { return analysis_task_parsers::appendOutput(outputs, element, hash); }, *task.get());
568583

569584
// request services

0 commit comments

Comments
 (0)