summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/http/http.cpp
diff options
context:
space:
mode:
authorhiddenpath <[email protected]>2025-02-18 12:34:23 +0300
committerhiddenpath <[email protected]>2025-02-18 13:18:25 +0300
commitb8ac60a673bd416577ca37b911409acbd32c7be2 (patch)
treec7a831e31968ebea4fbcdcb60fcd406193f208f5 /yt/cpp/mapreduce/http/http.cpp
parent75f5993689410f06224ace8767c11e2c71093fde (diff)
YT-23616: Remove HttpCode from TErrorResponse
commit_hash:412a7a1e02eb68d388aff73a439e98f6f2dab8a6
Diffstat (limited to 'yt/cpp/mapreduce/http/http.cpp')
-rw-r--r--yt/cpp/mapreduce/http/http.cpp12
1 files changed, 5 insertions, 7 deletions
diff --git a/yt/cpp/mapreduce/http/http.cpp b/yt/cpp/mapreduce/http/http.cpp
index 4bddeab86d1..47b9859605a 100644
--- a/yt/cpp/mapreduce/http/http.cpp
+++ b/yt/cpp/mapreduce/http/http.cpp
@@ -766,14 +766,12 @@ THttpResponse::THttpResponse(
return;
}
- ErrorResponse_ = TErrorResponse(HttpCode_, Context_.RequestId);
-
auto logAndSetError = [&] (int code, const TString& rawError) {
YT_LOG_ERROR("RSP %v - HTTP %v - %v",
Context_.RequestId,
HttpCode_,
rawError.data());
- ErrorResponse_->SetError(TYtError(code, rawError));
+ ErrorResponse_ = TErrorResponse(TYtError(code, rawError), Context_.RequestId);
};
switch (HttpCode_) {
@@ -807,8 +805,7 @@ THttpResponse::THttpResponse(
ExtendGenericError(*ErrorResponse_, NClusterErrorCodes::NBus::TransportError, "transport error");
}
} else {
- ErrorResponse_->SetRawError(
- errorString + " - X-YT-Error is missing in headers");
+ ErrorResponse_ = TErrorResponse(TYtError(errorString + " - X-YT-Error is missing in headers"), Context_.RequestId);
}
break;
}
@@ -854,8 +851,9 @@ TMaybe<TErrorResponse> THttpResponse::ParseError(const THttpHeaders& headers)
{
for (const auto& header : headers) {
if (header.Name() == "X-YT-Error") {
- TErrorResponse errorResponse(HttpCode_, Context_.RequestId);
- errorResponse.ParseFromJsonError(header.Value());
+ TYtError error;
+ error.ParseFrom(header.Value());
+ TErrorResponse errorResponse(std::move(error), Context_.RequestId);
if (errorResponse.IsOk()) {
return Nothing();
}