Skip to content

Commit a53fceb

Browse files
added query script
1 parent 642e800 commit a53fceb

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

ydb/core/viewer/json_local_rpc.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@ class TJsonLocalRpc : public TViewerPipeClient {
3333
std::vector<HTTP_METHOD> AllowedMethods = {};
3434
TAutoPtr<TEvLocalRpcPrivate::TEvGrpcRequestResult<TProtoResult>> Result;
3535
NThreading::TFuture<TProtoResponse> RpcFuture;
36+
Ydb::Operations::OperationParams::OperationMode OperationMode = Ydb::Operations::OperationParams::SYNC;
3637

3738
public:
3839
static constexpr NKikimrServices::TActivity::EType ActorActivityType() {
@@ -142,6 +143,7 @@ class TJsonLocalRpc : public TViewerPipeClient {
142143
void SendGrpcRequest(TProtoRequest&& request) {
143144
// TODO(xenoxeno): pass trace id
144145
RpcFuture = NRpcService::DoLocalRpc<TRpcEv>(std::move(request), Database, Event->Get()->UserToken, TlsActivationContext->ActorSystem());
146+
145147
RpcFuture.Subscribe([actorId = TBase::SelfId(), actorSystem = TlsActivationContext->ActorSystem()]
146148
(const NThreading::TFuture<TProtoResponse>& future) {
147149
auto& response = future.GetValueSync();

ydb/core/viewer/viewer_ut.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1885,7 +1885,6 @@ Y_UNIT_TEST_SUITE(Viewer) {
18851885
}
18861886

18871887
Y_UNIT_TEST(QueryExecuteScript) {
1888-
Cerr << "iiiiiii 0 " << Endl;
18891888
TPortManager tp;
18901889
ui16 port = tp.GetPort(2134);
18911890
ui16 grpcPort = tp.GetPort(2135);

0 commit comments

Comments
 (0)