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/http_client/rpc_parameters_serialization.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/http_client/rpc_parameters_serialization.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp b/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp index 8466df928bc..0963200dc66 100644 --- a/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp +++ b/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp @@ -534,10 +534,18 @@ TNode SerializeParamsForGetJob( TNode SerializeParamsForGetJobTrace( const TOperationId& operationId, - const TGetJobTraceOptions& /* options */) + const TJobId& jobId, + const TGetJobTraceOptions& options) { TNode result; SetOperationIdParam(&result, operationId); + result["job_id"] = GetGuidAsString(jobId); + if (options.FromTime_) { + result["from_time"] = ToString(options.FromTime_); + } + if (options.ToTime_) { + result["to_time"] = ToString(options.ToTime_); + } return result; } |
