diff options
| author | hiddenpath <[email protected]> | 2025-02-18 12:34:23 +0300 |
|---|---|---|
| committer | hiddenpath <[email protected]> | 2025-02-18 13:18:25 +0300 |
| commit | b8ac60a673bd416577ca37b911409acbd32c7be2 (patch) | |
| tree | c7a831e31968ebea4fbcdcb60fcd406193f208f5 /yt/cpp/mapreduce/http/http.cpp | |
| parent | 75f5993689410f06224ace8767c11e2c71093fde (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.cpp | 12 |
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(); } |
