diff options
| author | nadya73 <[email protected]> | 2024-04-18 12:01:09 +0300 |
|---|---|---|
| committer | nadya73 <[email protected]> | 2024-04-18 12:11:25 +0300 |
| commit | 044c22732c7e0fa5cbdd08543c7cd68a501170a6 (patch) | |
| tree | 1d2f571d26bd697eb3e30102cd8d90ae5a28a201 /yt/cpp/mapreduce/io/proto_table_reader.cpp | |
| parent | 4d77c1fb4de7a121c720a5b403ba7aa516a32ce3 (diff) | |
[yt/cpp/mapreduce] YT-21405: Don't ignore backoff and pass actual exception in Retry()
Don't ignore backoff and pass actual exception in Retry()
b821c02fd21c9f8115cd2a4896372a9fda69e5f6
Diffstat (limited to 'yt/cpp/mapreduce/io/proto_table_reader.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/io/proto_table_reader.cpp | 8 |
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; } } |