diff options
| author | gvit <gvit@ydb.tech> | 2023-09-28 12:18:14 +0300 |
|---|---|---|
| committer | gvit <gvit@ydb.tech> | 2023-09-28 12:42:06 +0300 |
| commit | 2b47072a5b83879d583a21bfa0be9770f05860c7 (patch) | |
| tree | 54349f215b93aec142ac55442e7044fef1e03fc5 | |
| parent | d89d3de523158dd97e8263955f40c68b465b0a81 (diff) | |
| download | ydb-2b47072a5b83879d583a21bfa0be9770f05860c7.tar.gz | |
return response counters to session actor KIKIMR-19394
| -rw-r--r-- | ydb/core/kqp/session_actor/kqp_session_actor.cpp | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/ydb/core/kqp/session_actor/kqp_session_actor.cpp b/ydb/core/kqp/session_actor/kqp_session_actor.cpp index bb757143853..9aa23b25476 100644 --- a/ydb/core/kqp/session_actor/kqp_session_actor.cpp +++ b/ydb/core/kqp/session_actor/kqp_session_actor.cpp @@ -1591,6 +1591,12 @@ public: } LWTRACK(KqpSessionReplyError, QueryState->Orbit, TStringBuilder() << status); } + + Counters->ReportResponseStatus(Settings.DbCounters, record.ByteSize(), record.GetYdbStatus()); + for (auto& issue : record.GetResponse().GetQueryIssues()) { + Counters->ReportIssues(Settings.DbCounters, issue); + } + Send(QueryState->Sender, QueryResponse.release(), 0, QueryState->ProxyRequestId); LOG_D("Sent query response back to proxy, proxyRequestId: " << QueryState->ProxyRequestId << ", proxyId: " << QueryState->Sender.ToString()); |