YT-24322: Retry cannot read from socket input stream error

hiddenpath · hiddenpath · commit 8457aaabdc89 · 2025-04-21T22:30:16.000+03:00
commit_hash:bdfb86ce1915fd5c298250f4973acf6343a3e226
diff --git a/yt/cpp/mapreduce/common/retry_lib.cpp b/yt/cpp/mapreduce/common/retry_lib.cpp
@@ -222,6 +222,7 @@ static TMaybe<TDuration> TryGetBackoffDuration(const TErrorResponse& errorRespon
     }
     for (auto code : {
         NRpc::TransportError,
+        NBus::TransportError,
         NRpc::Unavailable,
         NApi::RetriableArchiveError,
         NSequoiaClient::SequoiaRetriableError,
diff --git a/yt/cpp/mapreduce/http/http.cpp b/yt/cpp/mapreduce/http/http.cpp
@@ -49,7 +49,7 @@ std::exception_ptr WrapSystemError(
     }
 
     auto message = NYT::Format("Request %qv to %qv failed", context.RequestId, context.HostName + context.Method);
-    TYtError outer(1, message, {TYtError(NClusterErrorCodes::Generic, ex.what())}, {
+    TYtError outer(NClusterErrorCodes::NBus::TransportError, message, {TYtError(NClusterErrorCodes::Generic, ex.what())}, {
         {"request_id", context.RequestId},
         {"host", context.HostName},
         {"method", context.Method},

Original file line number	Diff line number	Diff line change
`@@ -222,6 +222,7 @@ static TMaybe<TDuration> TryGetBackoffDuration(const TErrorResponse& errorRespon`
`222`	`222`	`}`
`223`	`223`	`for (auto code : {`
`224`	`224`	`NRpc::TransportError,`
	`225`	`+ NBus::TransportError,`
`225`	`226`	`NRpc::Unavailable,`
`226`	`227`	`NApi::RetriableArchiveError,`
`227`	`228`	`NSequoiaClient::SequoiaRetriableError,`
Original file line number	Diff line number	Diff line change
`@@ -49,7 +49,7 @@ std::exception_ptr WrapSystemError(`
`49`	`49`	`}`
`50`	`50`
`51`	`51`	`auto message = NYT::Format("Request %qv to %qv failed", context.RequestId, context.HostName + context.Method);`
`52`		`- TYtError outer(1, message, {TYtError(NClusterErrorCodes::Generic, ex.what())}, {`
	`52`	`+ TYtError outer(NClusterErrorCodes::NBus::TransportError, message, {TYtError(NClusterErrorCodes::Generic, ex.what())}, {`
`53`	`53`	`{"request_id", context.RequestId},`
`54`	`54`	`{"host", context.HostName},`
`55`	`55`	`{"method", context.Method},`