aboutsummaryrefslogtreecommitdiffstats
path: root/yt
diff options
context:
space:
mode:
authoromgronny <omgronny@yandex-team.com>2024-07-09 14:02:39 +0300
committeromgronny <omgronny@yandex-team.com>2024-07-09 14:20:27 +0300
commit4ba52e9b2c9fe8455b38c2bae92f0c75025d9469 (patch)
tree80af4ea643793c3b3177fc1b0aa55672f0c9e1b5 /yt
parent1da5b68c73953286f4e4ec584947f201fd4998dd (diff)
downloadydb-4ba52e9b2c9fe8455b38c2bae92f0c75025d9469.tar.gz
YT-22131: Fix WithMonitoringDescriptor option in API
31ac1bd967ff46133f68b77b970a478d84ae3008
Diffstat (limited to 'yt')
-rw-r--r--yt/yt/client/api/rpc_proxy/helpers.cpp8
-rw-r--r--yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto1
2 files changed, 9 insertions, 0 deletions
diff --git a/yt/yt/client/api/rpc_proxy/helpers.cpp b/yt/yt/client/api/rpc_proxy/helpers.cpp
index 9269c90464..b0d079153c 100644
--- a/yt/yt/client/api/rpc_proxy/helpers.cpp
+++ b/yt/yt/client/api/rpc_proxy/helpers.cpp
@@ -966,6 +966,9 @@ void ToProto(NProto::TJob* protoJob, const NApi::TJob& job)
if (job.ArchiveFeatures) {
protoJob->set_archive_features(job.ArchiveFeatures.ToString());
}
+ if (job.MonitoringDescriptor) {
+ protoJob->set_monitoring_descriptor(*job.MonitoringDescriptor);
+ }
}
void FromProto(NApi::TJob* job, const NProto::TJob& protoJob)
@@ -1110,6 +1113,11 @@ void FromProto(NApi::TJob* job, const NProto::TJob& protoJob)
} else {
job->ArchiveFeatures = TYsonString();
}
+ if (protoJob.has_monitoring_descriptor()) {
+ job->MonitoringDescriptor = protoJob.monitoring_descriptor();
+ } else {
+ job->MonitoringDescriptor.reset();
+ }
}
void ToProto(
diff --git a/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto b/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto
index b036afcc8d..e0a2061690 100644
--- a/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto
+++ b/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto
@@ -3102,6 +3102,7 @@ message TJob
optional bool has_probing_competitors = 26;
optional uint64 job_cookie = 27;
optional bytes archive_features = 29; // YSON
+ optional string monitoring_descriptor = 30;
}
message TListJobsStatistics