diff options
author | nadya73 <nadya73@yandex-team.com> | 2024-04-18 12:01:09 +0300 |
---|---|---|
committer | nadya73 <nadya73@yandex-team.com> | 2024-04-18 12:11:25 +0300 |
commit | 044c22732c7e0fa5cbdd08543c7cd68a501170a6 (patch) | |
tree | 1d2f571d26bd697eb3e30102cd8d90ae5a28a201 /yt/cpp/mapreduce/interface/io.h | |
parent | 4d77c1fb4de7a121c720a5b403ba7aa516a32ce3 (diff) | |
download | ydb-044c22732c7e0fa5cbdd08543c7cd68a501170a6.tar.gz |
[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/interface/io.h')
-rw-r--r-- | yt/cpp/mapreduce/interface/io.h | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/interface/io.h b/yt/cpp/mapreduce/interface/io.h index 8497c8aae2..4f5480d107 100644 --- a/yt/cpp/mapreduce/interface/io.h +++ b/yt/cpp/mapreduce/interface/io.h @@ -142,7 +142,8 @@ public: /// from the stream. virtual bool Retry( const TMaybe<ui32>& rangeIndex, - const TMaybe<ui64>& rowIndex) = 0; + const TMaybe<ui64>& rowIndex, + const std::exception_ptr& error) = 0; /// Resets retry attempt count to the initial value (then `Retry()` can be called again). virtual void ResetRetries() = 0; |