aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/client/yt_poller.cpp
diff options
context:
space:
mode:
authorhiddenpath <hiddenpath@yandex-team.com>2025-01-15 20:17:09 +0300
committerhiddenpath <hiddenpath@yandex-team.com>2025-01-15 21:21:14 +0300
commitbb37d56338bace93813adc51a61936a19acc8edc (patch)
tree3d771660421001c994e2baf9a40b409d06c7a24b /yt/cpp/mapreduce/client/yt_poller.cpp
parent9a04c0af35c6a47061b3699089da07acfcf14587 (diff)
downloadydb-bb37d56338bace93813adc51a61936a19acc8edc.tar.gz
YT-23616: Make THttpRawBatchRequest as an implementation of IRawBatchRequest interface
commit_hash:9e6c556686dda1562697762d38da532dc5c87b80
Diffstat (limited to 'yt/cpp/mapreduce/client/yt_poller.cpp')
-rw-r--r--yt/cpp/mapreduce/client/yt_poller.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/yt/cpp/mapreduce/client/yt_poller.cpp b/yt/cpp/mapreduce/client/yt_poller.cpp
index 13670fddb5..4980d287fa 100644
--- a/yt/cpp/mapreduce/client/yt_poller.cpp
+++ b/yt/cpp/mapreduce/client/yt_poller.cpp
@@ -92,14 +92,14 @@ void TYtPoller::WatchLoop()
Y_ABORT_UNLESS(!InProgress_.empty());
}
- THttpRawBatchRequest rawBatchRequest(Context_.Config);
+ THttpRawBatchRequest rawBatchRequest(Context_, ClientRetryPolicy_->CreatePolicyForGenericRequest());
for (auto& item : InProgress_) {
item->PrepareRequest(&rawBatchRequest);
}
try {
- rawBatchRequest.ExecuteBatch(ClientRetryPolicy_->CreatePolicyForGenericRequest(), Context_);
+ rawBatchRequest.ExecuteBatch();
} catch (const std::exception& ex) {
YT_LOG_ERROR("Exception while executing batch request: %v", ex.what());
}