summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/client/file_reader.cpp
diff options
context:
space:
mode:
authorhiddenpath <[email protected]>2024-12-17 01:13:52 +0300
committerhiddenpath <[email protected]>2024-12-17 02:03:47 +0300
commit5935906b0bfd05ea9cf84fc03e1b7d8befd2ff11 (patch)
tree9f72ba6c791e8374a21699eb820767c9fbaa16a8 /yt/cpp/mapreduce/client/file_reader.cpp
parentb570317a503ddb08ae344d96997c4ebb45002b8d (diff)
[yt/cpp/mapreduce] YT-23616: Move Job methods to THttpRawClient
commit_hash:bd11304f4147ff314372d4ab6049478143f60fd5
Diffstat (limited to 'yt/cpp/mapreduce/client/file_reader.cpp')
-rw-r--r--yt/cpp/mapreduce/client/file_reader.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/yt/cpp/mapreduce/client/file_reader.cpp b/yt/cpp/mapreduce/client/file_reader.cpp
index 408650bda90..06463d0af24 100644
--- a/yt/cpp/mapreduce/client/file_reader.cpp
+++ b/yt/cpp/mapreduce/client/file_reader.cpp
@@ -98,7 +98,7 @@ size_t TStreamReaderBase::DoRead(void* buf, size_t len)
if (!IsRetriable(e) || attempt == retryCount) {
throw;
}
- NDetail::TWaitProxy::Get()->Sleep(GetBackoffDuration(e, Context_.Config));
+ TWaitProxy::Get()->Sleep(GetBackoffDuration(e, Context_.Config));
} catch (std::exception& e) {
YT_LOG_ERROR("RSP %v - failed: %v (attempt %v of %v)",
GetActiveRequestId(),
@@ -112,7 +112,7 @@ size_t TStreamReaderBase::DoRead(void* buf, size_t len)
if (attempt == retryCount) {
throw;
}
- NDetail::TWaitProxy::Get()->Sleep(GetBackoffDuration(e, Context_.Config));
+ TWaitProxy::Get()->Sleep(GetBackoffDuration(e, Context_.Config));
}
Input_ = nullptr;
}