We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2521715 commit 6f1f544Copy full SHA for 6f1f544
ydb/core/kqp/proxy_service/kqp_proxy_service.cpp
@@ -654,7 +654,11 @@ class TKqpProxyService : public TActorBootstrapped<TKqpProxyService> {
654
if (queryType == NKikimrKqp::QUERY_TYPE_SQL_GENERIC_QUERY ||
655
queryType == NKikimrKqp::QUERY_TYPE_SQL_GENERIC_CONCURRENT_QUERY) {
656
657
- if (explicitSession && sessionInfo && !sessionInfo->AttachedRpcId) {
+ if (explicitSession &&
658
+ sessionInfo &&
659
+ !sessionInfo->PgWire && // pg wire bypasses rpc layer and doesn't perform attach
660
+ !sessionInfo->AttachedRpcId)
661
+ {
662
TString error = "Attempt to execute query on explicit session without attach";
663
ReplyProcessError(Ydb::StatusIds::BAD_REQUEST, error, requestId);
664
return;
0 commit comments