|
21 | 21 | #include "Framework/DataRefUtils.h" |
22 | 22 | #include <Framework/InputRecord.h> |
23 | 23 | #include "Framework/InputRecordWalker.h" |
| 24 | +#include "DataSampling/DataSamplingHeader.h" |
24 | 25 | #include "DataFormatsTPC/TrackTPC.h" |
25 | 26 | #include "SimulationDataFormat/MCCompLabel.h" |
26 | 27 | #include "SimulationDataFormat/MCTruthContainer.h" |
@@ -80,7 +81,7 @@ static auto getWorkflowTPCInput(o2::framework::ProcessingContext& pc, int verbos |
80 | 81 | if (do_digits) { |
81 | 82 | std::fill(inputDigitsMCIndex.begin(), inputDigitsMCIndex.end(), -1); |
82 | 83 | } |
83 | | - for (auto const& ref : o2::framework::InputRecordWalker(pc.inputs(), filter)) { |
| 84 | + for (auto const& ref : o2::framework::InputRecordWalker<o2::utilities::DataSamplingHeader>(pc.inputs(), filter)) { |
84 | 85 | auto const* sectorHeader = o2::framework::DataRefUtils::getHeader<TPCSectorHeader*>(ref); |
85 | 86 | if (sectorHeader == nullptr) { |
86 | 87 | // FIXME: think about error policy |
@@ -127,7 +128,7 @@ static auto getWorkflowTPCInput(o2::framework::ProcessingContext& pc, int verbos |
127 | 128 | {"check", o2::framework::ConcreteDataTypeMatcher{o2::header::gDataOriginTPC, "CLUSTERNATIVE"}, o2::framework::Lifetime::Timeframe}, |
128 | 129 | }; |
129 | 130 | unsigned long recvMask = 0; |
130 | | - for (auto const& ref : o2::framework::InputRecordWalker(pc.inputs(), filter)) { |
| 131 | + for (auto const& ref : o2::framework::InputRecordWalker<o2::utilities::DataSamplingHeader>(pc.inputs(), filter)) { |
131 | 132 | auto const* sectorHeader = o2::framework::DataRefUtils::getHeader<TPCSectorHeader*>(ref); |
132 | 133 | if (sectorHeader == nullptr) { |
133 | 134 | throw std::runtime_error("sector header missing on header stack"); |
|
0 commit comments