aboutsummaryrefslogtreecommitdiffstats
path: root/yt
diff options
context:
space:
mode:
authoromgronny <omgronny@yandex-team.com>2023-11-08 16:24:11 +0300
committeromgronny <omgronny@yandex-team.com>2023-11-08 17:04:50 +0300
commitd88c733689000dd02540dc510ee98d7ed15daa70 (patch)
tree8af410eaaef8564df7fef0a8cb93308290288422 /yt
parent1cfb60d093d33df4c50825aa4fc71415a9d80db5 (diff)
downloadydb-d88c733689000dd02540dc510ee98d7ed15daa70.tar.gz
YT-17081: Add monitoring descriptor to map operations and to list_jobs
Diffstat (limited to 'yt')
-rw-r--r--yt/yt/client/api/operation_client.h1
-rw-r--r--yt/yt/client/api/rpc_proxy/client_impl.cpp3
-rw-r--r--yt/yt/client/driver/scheduler_commands.cpp2
-rw-r--r--yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto2
4 files changed, 8 insertions, 0 deletions
diff --git a/yt/yt/client/api/operation_client.h b/yt/yt/client/api/operation_client.h
index 364dabd409..9a0c0d1b9e 100644
--- a/yt/yt/client/api/operation_client.h
+++ b/yt/yt/client/api/operation_client.h
@@ -187,6 +187,7 @@ struct TListJobsOptions
std::optional<bool> WithFailContext;
std::optional<bool> WithSpec;
std::optional<bool> WithCompetitors;
+ std::optional<bool> WithMonitoringDescriptor;
std::optional<TString> TaskName;
TDuration RunningJobsLookbehindPeriod = TDuration::Max();
diff --git a/yt/yt/client/api/rpc_proxy/client_impl.cpp b/yt/yt/client/api/rpc_proxy/client_impl.cpp
index 3886b39910..33451d2904 100644
--- a/yt/yt/client/api/rpc_proxy/client_impl.cpp
+++ b/yt/yt/client/api/rpc_proxy/client_impl.cpp
@@ -1324,6 +1324,9 @@ TFuture<TListJobsResult> TClient::ListJobs(
if (options.WithCompetitors) {
req->set_with_competitors(*options.WithCompetitors);
}
+ if (options.WithMonitoringDescriptor) {
+ req->set_with_monitoring_descriptor(*options.WithMonitoringDescriptor);
+ }
if (options.TaskName) {
req->set_task_name(*options.TaskName);
}
diff --git a/yt/yt/client/driver/scheduler_commands.cpp b/yt/yt/client/driver/scheduler_commands.cpp
index fd871a3b6d..1d6a6bf9f0 100644
--- a/yt/yt/client/driver/scheduler_commands.cpp
+++ b/yt/yt/client/driver/scheduler_commands.cpp
@@ -278,6 +278,8 @@ TListJobsCommand::TListJobsCommand()
.Optional();
RegisterParameter("with_competitors", Options.WithCompetitors)
.Optional();
+ RegisterParameter("with_monitoring_descriptor", Options.WithMonitoringDescriptor)
+ .Optional();
RegisterParameter("job_competition_id", Options.JobCompetitionId)
.Optional();
RegisterParameter("task_name", Options.TaskName)
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 e5ee25c36a..4d76c67036 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
@@ -2173,6 +2173,8 @@ message TReqListJobs
optional string task_name = 19;
+ optional bool with_monitoring_descriptor = 21;
+
optional TMasterReadOptions master_read_options = 102;
}