diff options
author | Alexander Smirnov <alex@ydb.tech> | 2025-02-18 00:51:31 +0000 |
---|---|---|
committer | Alexander Smirnov <alex@ydb.tech> | 2025-02-18 00:51:31 +0000 |
commit | d46fe70ab3363efe215e4c7b142fb2e25e772f8e (patch) | |
tree | 1931cba78c3a24456f8f0dca6d80ba3cbc147acd /yt/cpp/mapreduce/common/retry_lib.cpp | |
parent | c25b7ee30559ef027fbc049354af1debffb6c1c6 (diff) | |
parent | 8fe93946bc369873a7ffbb3a7403463aa80e3117 (diff) | |
download | ydb-d46fe70ab3363efe215e4c7b142fb2e25e772f8e.tar.gz |
Merge branch 'rightlib' into merge-libs-250218-0050
Diffstat (limited to 'yt/cpp/mapreduce/common/retry_lib.cpp')
-rw-r--r-- | yt/cpp/mapreduce/common/retry_lib.cpp | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/yt/cpp/mapreduce/common/retry_lib.cpp b/yt/cpp/mapreduce/common/retry_lib.cpp index 826247cb57..53216bd3f8 100644 --- a/yt/cpp/mapreduce/common/retry_lib.cpp +++ b/yt/cpp/mapreduce/common/retry_lib.cpp @@ -203,16 +203,11 @@ static bool IsRetriableChunkError(const TSet<int>& codes) static TMaybe<TDuration> TryGetBackoffDuration(const TErrorResponse& errorResponse, const TConfigPtr& config) { - int httpCode = errorResponse.GetHttpCode(); - if (httpCode / 100 != 4 && !errorResponse.IsFromTrailers()) { - return config->RetryInterval; - } - auto allCodes = errorResponse.GetError().GetAllErrorCodes(); using namespace NClusterErrorCodes; - if (httpCode == 429 - || allCodes.count(NSecurityClient::RequestQueueSizeLimitExceeded) - || allCodes.count(NRpc::RequestQueueSizeLimitExceeded)) + + if (allCodes.count(NSecurityClient::RequestQueueSizeLimitExceeded) || + allCodes.count(NRpc::RequestQueueSizeLimitExceeded)) { // request rate limit exceeded return config->RateLimitExceededRetryInterval; |