Skip to content

Commit c9de14b

Browse files
author
mikari
committed
New concurrent flow view
commit_hash:320906aa75e48bd6c568ac227aafaa1091dbb647
1 parent 626e1b8 commit c9de14b

File tree

4 files changed

+12
-1
lines changed

4 files changed

+12
-1
lines changed

yt/yt/client/api/flow_client.h

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,9 @@ struct TSetPipelineDynamicSpecResult
7575

7676
struct TGetFlowViewOptions
7777
: public TTimeoutOptions
78-
{ };
78+
{
79+
bool Cache = true;
80+
};
7981

8082
struct TGetFlowViewResult
8183
{

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2728,6 +2728,7 @@ TFuture<TGetFlowViewResult> TClient::GetFlowView(
27282728

27292729
req->set_pipeline_path(pipelinePath);
27302730
req->set_view_path(viewPath);
2731+
req->set_cache(options.Cache);
27312732

27322733
return req->Invoke().Apply(BIND([] (const TApiServiceProxy::TRspGetFlowViewPtr& rsp) {
27332734
return TGetFlowViewResult{

yt/yt/client/driver/flow_commands.cpp

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -332,6 +332,13 @@ void TGetFlowViewCommand::Register(TRegistrar registrar)
332332
{
333333
registrar.Parameter("view_path", &TThis::ViewPath)
334334
.Default();
335+
336+
registrar.ParameterWithUniversalAccessor<bool>(
337+
"cache",
338+
[] (TThis* command) -> auto& {
339+
return command->Options.Cache;
340+
})
341+
.Optional(/*init*/ false);
335342
}
336343

337344
void TGetFlowViewCommand::DoExecute(ICommandContextPtr context)

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
@@ -3018,6 +3018,7 @@ message TReqGetFlowView
30183018
{
30193019
required bytes pipeline_path = 1; // YPath
30203020
optional bytes view_path = 2; // YPath
3021+
optional bool cache = 3 [default = true];
30213022
}
30223023

30233024
message TRspGetFlowView

0 commit comments

Comments
 (0)