Skip to content

Commit 0c70802

Browse files
Krock21mpereskokova
authored andcommitted
Add QueryTrackerStage to GetQueryTrackerInfo response. Pass stage through rpc calls
Issue: #823 --- d01cae68878432db1730f7ad8e4b2f063e15ff1a Pull Request resolved: ytsaurus/ytsaurus#825 Co-authored-by: mpereskokova <[email protected]>
1 parent 7797fb8 commit 0c70802

File tree

4 files changed

+4
-0
lines changed

4 files changed

+4
-0
lines changed

yt/yt/client/api/query_tracker_client.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -152,6 +152,7 @@ struct TGetQueryTrackerInfoOptions
152152

153153
struct TGetQueryTrackerInfoResult
154154
{
155+
TString QueryTrackerStage;
155156
TString ClusterName;
156157
NYson::TYsonString SupportedFeatures;
157158
std::vector<TString> AccessControlObjects;

yt/yt/client/api/rpc_proxy/client_impl.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2406,6 +2406,7 @@ TFuture<TGetQueryTrackerInfoResult> TClient::GetQueryTrackerInfo(
24062406

24072407
return req->Invoke().Apply(BIND([] (const TApiServiceProxy::TRspGetQueryTrackerInfoPtr& rsp) {
24082408
return TGetQueryTrackerInfoResult{
2409+
.QueryTrackerStage = rsp->query_tracker_stage(),
24092410
.ClusterName = rsp->cluster_name(),
24102411
.SupportedFeatures = TYsonString(rsp->supported_features()),
24112412
.AccessControlObjects = FromProto<std::vector<TString>>(rsp->access_control_objects()),

yt/yt/client/driver/query_commands.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -386,6 +386,7 @@ void TGetQueryTrackerInfoCommand::DoExecute(ICommandContextPtr context)
386386

387387
context->ProduceOutputValue(BuildYsonStringFluently()
388388
.BeginMap()
389+
.Item("query_tracker_stage").Value(result.QueryTrackerStage)
389390
.Item("cluster_name").Value(result.ClusterName)
390391
.Item("supported_features").Value(result.SupportedFeatures)
391392
.Item("access_control_objects").Value(result.AccessControlObjects)

yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3368,6 +3368,7 @@ message TRspGetQueryTrackerInfo
33683368
required string cluster_name = 1;
33693369
required bytes supported_features = 2; // YSON
33703370
repeated string access_control_objects = 3;
3371+
optional string query_tracker_stage = 4;
33713372
}
33723373

33733374
////////////////////////////////////////////////////////////////////////////////

0 commit comments

Comments
 (0)