@@ -268,11 +268,11 @@ AlgorithmSpec AODJAlienReaderHelpers::rootFileReaderCallback(ConfigContext const
268268
269269 int64_t startTime = uv_hrtime ();
270270 int64_t startSize = totalSizeCompressed;
271- auto skipInvalidRead = [&](header::DataHeader const & dh , InvalidAODReadError const & e) {
271+ auto skipInvalidRead = [&](ConcreteDataMatcher const & concrete , InvalidAODReadError const & e) {
272272 auto skippedTimeframes = ++totalInvalidReadSkipped;
273273 LOGP (error, " Invalid AOD read for table {}: fileCounter {}, timeFrame {}. Skipping timeframe (skipped timeframes: {}). Reason: {}" ,
274- dh. dataOrigin .as <std::string>(), fcnt, ntf, skippedTimeframes, describeException (e));
275- didir->markTimeFrameSkipped (dh , ntf);
274+ concrete. origin .as <std::string>(), fcnt, ntf, skippedTimeframes, describeException (e));
275+ didir->markTimeFrameSkipped (header::DataHeader (concrete. description , concrete. origin , concrete. subSpec ) , ntf);
276276 arrowContext.clear ();
277277 messageContext.discard ();
278278 stringContext.clear ();
@@ -335,7 +335,7 @@ AlgorithmSpec AODJAlienReaderHelpers::rootFileReaderCallback(ConfigContext const
335335 if (!skipInvalidReads) {
336336 throw ;
337337 }
338- skipInvalidRead (dh , e);
338+ skipInvalidRead (concrete , e);
339339 return TFReaderState::INVALID_TIMEFRAME ;
340340 }
341341
0 commit comments