summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/client/client.cpp
diff options
context:
space:
mode:
authorhiddenpath <[email protected]>2024-12-22 15:24:42 +0300
committerhiddenpath <[email protected]>2024-12-22 15:39:23 +0300
commitf91c945c6cea13291b6b00349ebe71f646a03245 (patch)
tree9707faad5092a1b10785bcebca1c9067ffb83e56 /yt/cpp/mapreduce/client/client.cpp
parent808bc855f593ba184a4a1886a083b0f220e811b7 (diff)
YT-23616: Return IHttpResponsePtr instead of TResponseInfo
commit_hash:15e9e482495b418a4e9f54ad7c423f0bba0d9f14
Diffstat (limited to 'yt/cpp/mapreduce/client/client.cpp')
-rw-r--r--yt/cpp/mapreduce/client/client.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/yt/cpp/mapreduce/client/client.cpp b/yt/cpp/mapreduce/client/client.cpp
index 69f0147a66a..10712e319a6 100644
--- a/yt/cpp/mapreduce/client/client.cpp
+++ b/yt/cpp/mapreduce/client/client.cpp
@@ -1355,9 +1355,9 @@ TNode::TListType TClient::SkyShareTable(
// As documented at https://wiki.yandex-team.ru/yt/userdoc/blob_tables/#shag3.sozdajomrazdachu
// first request returns HTTP status code 202 (Accepted). And we need retrying until we have 200 (OK).
- TResponseInfo response;
- while (response.HttpCode != 200) {
- response = RequestWithRetry<TResponseInfo>(
+ NHttpClient::IHttpResponsePtr response;
+ while (response->GetStatusCode() != 200) {
+ response = RequestWithRetry<NHttpClient::IHttpResponsePtr>(
ClientRetryPolicy_->CreatePolicyForGenericRequest(),
[this, &tablePaths, &options] (TMutationId /*mutationId*/) {
return RawClient_->SkyShareTable(tablePaths, options);
@@ -1366,11 +1366,11 @@ TNode::TListType TClient::SkyShareTable(
}
if (options.KeyColumns_) {
- return NodeFromJsonString(response.Response)["torrents"].AsList();
+ return NodeFromJsonString(response->GetResponse())["torrents"].AsList();
} else {
TNode torrent;
torrent["key"] = TNode::CreateList();
- torrent["rbtorrent"] = response.Response;
+ torrent["rbtorrent"] = response->GetResponse();
return TNode::TListType{torrent};
}
}