Skip to content

Commit 009202c

Browse files
committed
account for pre-replaced origins
1 parent 75d7b17 commit 009202c

3 files changed

Lines changed: 4 additions & 7 deletions

File tree

Framework/Core/include/Framework/ASoA.h

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1824,12 +1824,6 @@ consteval auto computeOriginals()
18241824
return o2::soa::mergeOriginals<Ts...>();
18251825
}
18261826

1827-
// template <size_t N, std::array<TableRef, N> refs>
1828-
// consteval auto commonOrigin()
1829-
// {
1830-
// return (refs | std::ranges::views::filter([](TableRef const& r) { return (!(r.origin_hash == "DYN"_h || r.origin_hash == "IDX"_h)); })).front().origin_hash;
1831-
// }
1832-
18331827
/// A Table class which observes an arrow::Table and provides
18341828
/// It is templated on a set of Column / DynamicColumn types.
18351829
template <aod::is_aod_hash L, aod::is_aod_hash D, aod::is_origin_hash O, typename... Ts>

Framework/Core/include/Framework/AnalysisHelpers.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -429,7 +429,7 @@ constexpr auto tableRef2InputSpec(header::DataOrigin newOrigin = header::DataOri
429429
std::ranges::transform(sources, sources.begin(), [originStr = newOrigin.as<std::string>()](framework::ConfigParamSpec& source) {
430430
return replaceOrigin(source, originStr);
431431
});
432-
metadata.push_back(framework::ConfigParamSpec{"aod-origin-replaced", framework::VariantType::Bool, true, {"\"\""}});
432+
metadata.emplace_back(framework::ConfigParamSpec{"aod-origin-replaced", framework::VariantType::Bool, true, {"\"\""}});
433433
}
434434
metadata.insert(metadata.end(), sources.begin(), sources.end());
435435
auto ccdbURLs = getCCDBMetadata<typename o2::aod::MetadataTrait<o2::aod::Hash<R.desc_hash>>::metadata>();

Framework/Core/include/Framework/AnalysisTask.h

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -97,6 +97,9 @@ struct AnalysisDataProcessorBuilder {
9797
static void addOriginalRef(const char* name, bool value, std::vector<InputSpec>& inputs, std::vector<InputInfo>& iInfos, int ai, uint32_t hash, header::DataOrigin newOrigin = header::DataOrigin{"AOD"})
9898
{
9999
auto spec = soa::tableRef2InputSpec<R>(newOrigin);
100+
if (R.origin_hash != "AOD"_h) {
101+
spec.metadata.emplace_back(ConfigParamSpec{"aod-origin-replaced", VariantType::Bool, true, {"\"\""}});
102+
}
100103
spec.metadata.emplace_back(ConfigParamSpec{std::string{"control:"} + name, VariantType::Bool, value, {"\"\""}});
101104
auto matcher = DataSpecUtils::asConcreteDataMatcher(spec);
102105
DataSpecUtils::updateInputList(inputs, std::move(spec));

0 commit comments

Comments
 (0)