diff options
| author | hiddenpath <[email protected]> | 2024-12-17 01:13:52 +0300 |
|---|---|---|
| committer | hiddenpath <[email protected]> | 2024-12-17 02:03:47 +0300 |
| commit | 5935906b0bfd05ea9cf84fc03e1b7d8befd2ff11 (patch) | |
| tree | 9f72ba6c791e8374a21699eb820767c9fbaa16a8 /yt/cpp/mapreduce/client/file_reader.cpp | |
| parent | b570317a503ddb08ae344d96997c4ebb45002b8d (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.cpp | 4 |
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; } |
