aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/common/retry_lib.cpp
diff options
context:
space:
mode:
authorAlexander Smirnov <alex@ydb.tech>2025-02-18 00:51:31 +0000
committerAlexander Smirnov <alex@ydb.tech>2025-02-18 00:51:31 +0000
commitd46fe70ab3363efe215e4c7b142fb2e25e772f8e (patch)
tree1931cba78c3a24456f8f0dca6d80ba3cbc147acd /yt/cpp/mapreduce/common/retry_lib.cpp
parentc25b7ee30559ef027fbc049354af1debffb6c1c6 (diff)
parent8fe93946bc369873a7ffbb3a7403463aa80e3117 (diff)
downloadydb-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.cpp11
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;