YT-24624: Rework get_job_trace api

<Message NOT for release notes>

* Changelog entry
  Type: fix
  Component: scheduler

Rework get\_job\_trace api: enable streaming and return perfetto-friendly format
commit_hash:082e255afb9022eb137dac3d0c3be8ac49d3b5e2

1 files changed, 7 insertions, 14 deletions

diff --git a/yt/cpp/mapreduce/http_client/raw_client.cpp b/yt/cpp/mapreduce/http_client/raw_client.cpp
index b1207cc8984..abfeabefad7 100644
--- a/yt/cpp/mapreduce/http_client/raw_client.cpp
+++ b/yt/cpp/mapreduce/http_client/raw_client.cpp
@@ -541,25 +541,18 @@ TJobTraceEvent ParseJobTraceEvent(const TNode& node)
     return result;
 }
 
-std::vector<TJobTraceEvent> THttpRawClient::GetJobTrace(
+IFileReaderPtr THttpRawClient::GetJobTrace(
     const TOperationId& operationId,
+    const TJobId& jobId,
     const TGetJobTraceOptions& options)
 {
     TMutationId mutationId;
     THttpHeader header("GET", "get_job_trace");
-    header.MergeParameters(NRawClient::SerializeParamsForGetJobTrace(operationId, options));
-    auto responseInfo = RequestWithoutRetry(Context_, mutationId, header);
-    auto resultNode = NodeFromYsonString(responseInfo->GetResponse());
-
-    const auto& traceEventNodesList = resultNode.AsList();
-
-    std::vector<TJobTraceEvent> result;
-    result.reserve(traceEventNodesList.size());
-    for (const auto& traceEventNode : traceEventNodesList) {
-        result.push_back(ParseJobTraceEvent(traceEventNode));
-    }
-
-    return result;
+    header.MergeParameters(NRawClient::SerializeParamsForGetJobTrace(operationId, jobId, options));
+    TRequestConfig config;
+    config.IsHeavy = true;
+    auto responseInfo = RequestWithoutRetry(Context_, mutationId, header, /*body*/ {}, config);
+    return MakeIntrusive<NHttpClient::THttpResponseStream>(std::move(responseInfo));
 }
 
 std::unique_ptr<IInputStream> THttpRawClient::ReadFile(