diff options
| author | hiddenpath <[email protected]> | 2024-12-22 15:24:42 +0300 |
|---|---|---|
| committer | hiddenpath <[email protected]> | 2024-12-22 15:39:23 +0300 |
| commit | f91c945c6cea13291b6b00349ebe71f646a03245 (patch) | |
| tree | 9707faad5092a1b10785bcebca1c9067ffb83e56 /yt/cpp/mapreduce/client/client.cpp | |
| parent | 808bc855f593ba184a4a1886a083b0f220e811b7 (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.cpp | 10 |
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}; } } |
