diff options
| author | omgronny <omgronny@yandex-team.com> | 2023-11-08 16:24:11 +0300 |
|---|---|---|
| committer | omgronny <omgronny@yandex-team.com> | 2023-11-08 17:04:50 +0300 |
| commit | d88c733689000dd02540dc510ee98d7ed15daa70 (patch) | |
| tree | 8af410eaaef8564df7fef0a8cb93308290288422 /yt | |
| parent | 1cfb60d093d33df4c50825aa4fc71415a9d80db5 (diff) | |
| download | ydb-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.h | 1 | ||||
| -rw-r--r-- | yt/yt/client/api/rpc_proxy/client_impl.cpp | 3 | ||||
| -rw-r--r-- | yt/yt/client/driver/scheduler_commands.cpp | 2 | ||||
| -rw-r--r-- | yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto | 2 |
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; } |