summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp
diff options
context:
space:
mode:
authorbystrovserg <[email protected]>2025-10-17 19:32:57 +0300
committerbystrovserg <[email protected]>2025-10-17 20:16:41 +0300
commit9ff4ecace8645ecd5746e7754247187c81a6da5e (patch)
treed457382a71753fca12dc9cf0aa728ca6fccf4db8 /yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp
parent8304b8be525bda6b9b355b806d18d6f5ed8dff79 (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.cpp10
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;
}