diff options
| author | bystrovserg <[email protected]> | 2025-10-17 19:32:57 +0300 |
|---|---|---|
| committer | bystrovserg <[email protected]> | 2025-10-17 20:16:41 +0300 |
| commit | 9ff4ecace8645ecd5746e7754247187c81a6da5e (patch) | |
| tree | d457382a71753fca12dc9cf0aa728ca6fccf4db8 /yt/cpp/mapreduce/client/client.cpp | |
| parent | 8304b8be525bda6b9b355b806d18d6f5ed8dff79 (diff) | |
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
Diffstat (limited to 'yt/cpp/mapreduce/client/client.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/client/client.cpp | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/yt/cpp/mapreduce/client/client.cpp b/yt/cpp/mapreduce/client/client.cpp index ab616c3aace..c060634ec4e 100644 --- a/yt/cpp/mapreduce/client/client.cpp +++ b/yt/cpp/mapreduce/client/client.cpp @@ -1409,16 +1409,13 @@ IFileReaderPtr TClient::GetJobStderr( return RawClient_->GetJobStderr(operationId, jobId, options); } -std::vector<TJobTraceEvent> TClient::GetJobTrace( +IFileReaderPtr TClient::GetJobTrace( const TOperationId& operationId, + const TJobId& jobId, const TGetJobTraceOptions& options) { CheckShutdown(); - return RequestWithRetry<std::vector<TJobTraceEvent>>( - ClientRetryPolicy_->CreatePolicyForGenericRequest(), - [this, &operationId, &options] (TMutationId /*mutationId*/) { - return RawClient_->GetJobTrace(operationId, options); - }); + return RawClient_->GetJobTrace(operationId, jobId, options); } TNode::TListType TClient::SkyShareTable( |