summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/io/proto_table_reader.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'yt/cpp/mapreduce/io/proto_table_reader.cpp')
-rw-r--r--yt/cpp/mapreduce/io/proto_table_reader.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/yt/cpp/mapreduce/io/proto_table_reader.cpp b/yt/cpp/mapreduce/io/proto_table_reader.cpp
index c0bf90d2536..6f79619c810 100644
--- a/yt/cpp/mapreduce/io/proto_table_reader.cpp
+++ b/yt/cpp/mapreduce/io/proto_table_reader.cpp
@@ -238,8 +238,8 @@ void TLenvalProtoTableReader::ReadRow(Message* row)
Input_.ResetRetries();
break;
- } catch (const std::exception& ) {
- if (!TLenvalTableReader::Retry()) {
+ } catch (const std::exception& ex) {
+ if (!TLenvalTableReader::Retry(std::make_exception_ptr(ex))) {
throw;
}
}
@@ -300,8 +300,8 @@ void TLenvalProtoTableReader::SkipRow()
ythrow yexception() << "Premature end of stream";
}
break;
- } catch (const std::exception& ) {
- if (!TLenvalTableReader::Retry()) {
+ } catch (const std::exception& ex) {
+ if (!TLenvalTableReader::Retry(std::make_exception_ptr(ex))) {
throw;
}
}