Skip to content

Commit a69a693

Browse files
evanevanevanevannnnevanevanevanevannnn
authored
Merge 56eab64 into 8d55710 
2 parents 8d55710 + 56eab64 commit a69a693

36 files changed

+297
-231
lines changed

‎ydb/core/fq/libs/actors/database_resolver.cpp‎

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
#include <ydb/core/fq/libs/common/cache.h>
55
#include <ydb/core/fq/libs/config/protos/issue_id.pb.h>
66
#include <ydb/core/fq/libs/events/events.h>
7-
#include <ydb/core/fq/libs/exceptions/exceptions.h>
7+
#include <ydb/library/yql/utils/exceptions.h>
88
#include <ydb/core/util/tuples.h>
99
#include <ydb/library/services/services.pb.h>
1010
#include <ydb/library/yql/providers/common/db_id_async_resolver/db_async_resolver.h>
@@ -213,11 +213,13 @@ class TResponseProcessor : public TActorBootstrapped<TResponseProcessor>
213213
DatabaseId2Description[std::make_pair(params.Id, params.DatabaseType)] = description;
214214
result.ConstructInPlace(description);
215215
return "";
216-
} catch (const TCodeLineException& ex) {
216+
} catch (const NYql::TCodeLineException& ex) {
217+
LOG_E("ResponseProcessor::Handle(HttpIncomingResponse): " << ex.what());
217218
return TStringBuilder()
218219
<< "response parser error: " << params.ToDebugString() << Endl
219220
<< ex.GetRawMessage();
220221
} catch (...) {
222+
LOG_E("ResponseProcessor::Handle(HttpIncomingResponse): " << CurrentExceptionMessage());
221223
return TStringBuilder()
222224
<< "response parser error: " << params.ToDebugString() << Endl
223225
<< CurrentExceptionMessage();
@@ -359,7 +361,7 @@ class TDatabaseResolver: public TActor<TDatabaseResolver>
359361
}
360362

361363
if (aliveHosts.empty()) {
362-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "No ALIVE ClickHouse hosts found";
364+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "No ALIVE ClickHouse hosts found";
363365
}
364366

365367
NYql::IMdbEndpointGenerator::TParams params = {
@@ -407,7 +409,7 @@ class TDatabaseResolver: public TActor<TDatabaseResolver>
407409
}
408410

409411
if (aliveHosts.empty()) {
410-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "No ALIVE PostgreSQL hosts found";
412+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "No ALIVE PostgreSQL hosts found";
411413
}
412414

413415
NYql::IMdbEndpointGenerator::TParams params = {
@@ -445,7 +447,7 @@ class TDatabaseResolver: public TActor<TDatabaseResolver>
445447
}
446448

447449
if (aliveHost == "") {
448-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "No ALIVE Greenplum hosts found";
450+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "No ALIVE Greenplum hosts found";
449451
}
450452

451453
NYql::IMdbEndpointGenerator::TParams params = {
@@ -495,7 +497,7 @@ class TDatabaseResolver: public TActor<TDatabaseResolver>
495497
}
496498

497499
if (aliveHosts.empty()) {
498-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "No ALIVE MySQL hosts found";
500+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "No ALIVE MySQL hosts found";
499501
}
500502

501503
NYql::IMdbEndpointGenerator::TParams params = {

‎ydb/core/fq/libs/actors/ya.make‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,6 @@ PEERDIR(
4343
ydb/core/fq/libs/db_id_async_resolver_impl
4444
ydb/core/fq/libs/db_schema
4545
ydb/core/fq/libs/events
46-
ydb/core/fq/libs/exceptions
4746
ydb/core/fq/libs/grpc
4847
ydb/core/fq/libs/private_client
4948
ydb/core/fq/libs/rate_limiter/utils

‎ydb/core/fq/libs/config/yq_issue.cpp‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5,28 +5,28 @@
55

66
namespace NFq {
77

8-
NYql::TIssue MakeFatalIssue(TIssuesIds::EIssueCode id, const TString& message) {
8+
NYql::TIssue MakeFatalIssue(ui32 id, const TString& message) {
99
NYql::TIssue issue;
1010
issue.SetCode(id, NYql::TSeverityIds::S_FATAL);
1111
issue.SetMessage(message);
1212
return issue;
1313
}
1414

15-
NYql::TIssue MakeErrorIssue(TIssuesIds::EIssueCode id, const TString& message) {
15+
NYql::TIssue MakeErrorIssue(ui32 id, const TString& message) {
1616
NYql::TIssue issue;
1717
issue.SetCode(id, NYql::TSeverityIds::S_ERROR);
1818
issue.SetMessage(message);
1919
return issue;
2020
}
2121

22-
NYql::TIssue MakeWarningIssue(TIssuesIds::EIssueCode id, const TString& message) {
22+
NYql::TIssue MakeWarningIssue(ui32 id, const TString& message) {
2323
NYql::TIssue issue;
2424
issue.SetCode(id, NYql::TSeverityIds::S_WARNING);
2525
issue.SetMessage(message);
2626
return issue;
2727
}
2828

29-
NYql::TIssue MakeInfoIssue(TIssuesIds::EIssueCode id, const TString& message) {
29+
NYql::TIssue MakeInfoIssue(ui32 id, const TString& message) {
3030
NYql::TIssue issue;
3131
issue.SetCode(id, NYql::TSeverityIds::S_INFO);
3232
issue.SetMessage(message);

‎ydb/core/fq/libs/config/yq_issue.h‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,12 @@
66

77
namespace NFq {
88

9-
NYql::TIssue MakeFatalIssue(TIssuesIds::EIssueCode id, const TString& message);
9+
NYql::TIssue MakeFatalIssue(ui32 id, const TString& message);
1010

11-
NYql::TIssue MakeErrorIssue(TIssuesIds::EIssueCode id, const TString& message);
11+
NYql::TIssue MakeErrorIssue(ui32 id, const TString& message);
1212

13-
NYql::TIssue MakeWarningIssue(TIssuesIds::EIssueCode id, const TString& message);
13+
NYql::TIssue MakeWarningIssue(ui32 id, const TString& message);
1414

15-
NYql::TIssue MakeInfoIssue(TIssuesIds::EIssueCode id, const TString& message);
15+
NYql::TIssue MakeInfoIssue(ui32 id, const TString& message);
1616

1717
}

‎ydb/core/fq/libs/control_plane_storage/extractors.h‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ TValidationQuery CreateEntityExtractor(const TString& scope,
2929
auto validator = [response, entityColumnName, parseProtobufError](NYdb::NTable::TDataQueryResult result) {
3030
const auto& resultSets = result.GetResultSets();
3131
if (resultSets.size() != 1) {
32-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "internal error, result set size is not equal to 1 but equal " << resultSets.size();
32+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "internal error, result set size is not equal to 1 but equal " << resultSets.size();
3333
}
3434

3535
NYdb::TResultSetParser parser(resultSets.back());
@@ -39,7 +39,7 @@ TValidationQuery CreateEntityExtractor(const TString& scope,
3939

4040
if (!response->second.Before.ConstructInPlace().ParseFromString(*parser.ColumnParser(entityColumnName).GetOptionalString())) {
4141
parseProtobufError->Inc();
42-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "Error parsing proto message. Please contact internal support";
42+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "Error parsing proto message. Please contact internal support";
4343
}
4444
return false;
4545
};

‎ydb/core/fq/libs/control_plane_storage/internal/task_get.cpp‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -161,13 +161,13 @@ std::tuple<TString, NYdb::TParams, std::function<std::pair<TString, NYdb::TParam
161161

162162
if (!task.Query.ParseFromString(*parser.ColumnParser(QUERY_COLUMN_NAME).GetOptionalString())) {
163163
commonCounters->ParseProtobufError->Inc();
164-
throw TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "Error parsing proto message for query. Please contact internal support";
164+
throw NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "Error parsing proto message for query. Please contact internal support";
165165
}
166166
const TInstant deadline = TInstant::Now() + (task.Query.content().automatic() ? std::min(automaticQueriesTtl, resultSetsTtl) : resultSetsTtl);
167167
task.Deadline = deadline;
168168
if (!task.Internal.ParseFromString(*parser.ColumnParser(INTERNAL_COLUMN_NAME).GetOptionalString())) {
169169
commonCounters->ParseProtobufError->Inc();
170-
throw TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "Error parsing proto message for query internal. Please contact internal support";
170+
throw NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "Error parsing proto message for query internal. Please contact internal support";
171171
}
172172

173173
*task.Internal.mutable_result_ttl() = NProtoInterop::CastToProto(resultSetsTtl);

‎ydb/core/fq/libs/control_plane_storage/internal/task_ping.cpp‎

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -99,32 +99,32 @@ TPingTaskParams ConstructHardPingTask(
9999
TString owner;
100100

101101
if (resultSets.size() != 3) {
102-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "RESULT SET SIZE of " << resultSets.size() << " != 3";
102+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "RESULT SET SIZE of " << resultSets.size() << " != 3";
103103
}
104104

105105
{
106106
TResultSetParser parser(resultSets[0]);
107107
if (!parser.TryNextRow()) {
108-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "NOT FOUND " QUERIES_TABLE_NAME " where " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\" and " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\"";
108+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "NOT FOUND " QUERIES_TABLE_NAME " where " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\" and " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\"";
109109
}
110110
if (!query.ParseFromString(*parser.ColumnParser(QUERY_COLUMN_NAME).GetOptionalString())) {
111111
commonCounters->ParseProtobufError->Inc();
112-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "ERROR PARSING " QUERIES_TABLE_NAME "." QUERY_COLUMN_NAME " where " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\" and " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\"";
112+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "ERROR PARSING " QUERIES_TABLE_NAME "." QUERY_COLUMN_NAME " where " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\" and " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\"";
113113
}
114114
if (!internal.ParseFromString(*parser.ColumnParser(INTERNAL_COLUMN_NAME).GetOptionalString())) {
115115
commonCounters->ParseProtobufError->Inc();
116-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "ERROR PARSING " QUERIES_TABLE_NAME "." INTERNAL_COLUMN_NAME " where " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\" and " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\"";
116+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "ERROR PARSING " QUERIES_TABLE_NAME "." INTERNAL_COLUMN_NAME " where " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\" and " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\"";
117117
}
118118
}
119119

120120
{
121121
TResultSetParser parser(resultSets[1]);
122122
if (!parser.TryNextRow()) {
123-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "NOT FOUND " JOBS_TABLE_NAME " where " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\" and " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\"";
123+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "NOT FOUND " JOBS_TABLE_NAME " where " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\" and " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\"";
124124
}
125125
if (!job.ParseFromString(*parser.ColumnParser(JOB_COLUMN_NAME).GetOptionalString())) {
126126
commonCounters->ParseProtobufError->Inc();
127-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "ERROR PARSING " JOBS_TABLE_NAME "." JOB_COLUMN_NAME " where " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\" and " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\"";
127+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "ERROR PARSING " JOBS_TABLE_NAME "." JOB_COLUMN_NAME " where " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\" and " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\"";
128128
}
129129
jobId = *parser.ColumnParser(JOB_ID_COLUMN_NAME).GetOptionalString();
130130
}
@@ -133,11 +133,11 @@ TPingTaskParams ConstructHardPingTask(
133133
{
134134
TResultSetParser parser(resultSets[2]);
135135
if (!parser.TryNextRow()) {
136-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "NOT FOUND " PENDING_SMALL_TABLE_NAME " where " TENANT_COLUMN_NAME " = \"" << request.tenant() << "\" and " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\" and " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\"" ;
136+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "NOT FOUND " PENDING_SMALL_TABLE_NAME " where " TENANT_COLUMN_NAME " = \"" << request.tenant() << "\" and " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\" and " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\"" ;
137137
}
138138
owner = *parser.ColumnParser(OWNER_COLUMN_NAME).GetOptionalString();
139139
if (owner != request.owner_id()) {
140-
ythrow TCodeLineException(TIssuesIds::BAD_REQUEST) << "OWNER of QUERY ID = \"" << request.query_id().value() << "\" MISMATCHED: \"" << request.owner_id() << "\" (received) != \"" << owner << "\" (selected)";
140+
ythrow NYql::TCodeLineException(TIssuesIds::BAD_REQUEST) << "OWNER of QUERY ID = \"" << request.query_id().value() << "\" MISMATCHED: \"" << request.owner_id() << "\" (received) != \"" << owner << "\" (selected)";
141141
}
142142
retryLimiter.Assign(
143143
parser.ColumnParser(RETRY_COUNTER_COLUMN_NAME).GetOptionalUint64().GetOrElse(0),
@@ -408,15 +408,15 @@ TPingTaskParams ConstructHardPingTask(
408408
}
409409

410410
if (job.ByteSizeLong() > maxRequestSize) {
411-
ythrow TCodeLineException(TIssuesIds::BAD_REQUEST) << "Job proto exceeded the size limit: " << job.ByteSizeLong() << " of " << maxRequestSize << " " << TSizeFormatPrinter(job).ToString();
411+
ythrow NYql::TCodeLineException(TIssuesIds::BAD_REQUEST) << "Job proto exceeded the size limit: " << job.ByteSizeLong() << " of " << maxRequestSize << " " << TSizeFormatPrinter(job).ToString();
412412
}
413413

414414
if (query.ByteSizeLong() > maxRequestSize) {
415-
ythrow TCodeLineException(TIssuesIds::BAD_REQUEST) << "Query proto exceeded the size limit: " << query.ByteSizeLong() << " of " << maxRequestSize << " " << TSizeFormatPrinter(query).ToString();
415+
ythrow NYql::TCodeLineException(TIssuesIds::BAD_REQUEST) << "Query proto exceeded the size limit: " << query.ByteSizeLong() << " of " << maxRequestSize << " " << TSizeFormatPrinter(query).ToString();
416416
}
417417

418418
if (internal.ByteSizeLong() > maxRequestSize) {
419-
ythrow TCodeLineException(TIssuesIds::BAD_REQUEST) << "QueryInternal proto exceeded the size limit: " << internal.ByteSizeLong() << " of " << maxRequestSize << " " << TSizeFormatPrinter(internal).ToString();
419+
ythrow NYql::TCodeLineException(TIssuesIds::BAD_REQUEST) << "QueryInternal proto exceeded the size limit: " << internal.ByteSizeLong() << " of " << maxRequestSize << " " << TSizeFormatPrinter(internal).ToString();
420420
}
421421

422422
finalStatus->Status = query.meta().status();
@@ -568,29 +568,29 @@ TPingTaskParams ConstructSoftPingTask(
568568
FederatedQuery::Internal::QueryInternal internal;
569569

570570
if (resultSets.size() != 2) {
571-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "RESULT SET SIZE of " << resultSets.size() << " != 2";
571+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "RESULT SET SIZE of " << resultSets.size() << " != 2";
572572
}
573573

574574
{
575575
TResultSetParser parser(resultSets[0]);
576576
if (!parser.TryNextRow()) {
577-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "NOT FOUND " QUERIES_TABLE_NAME " where " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\" and " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\"" ;
577+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "NOT FOUND " QUERIES_TABLE_NAME " where " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\" and " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\"" ;
578578
}
579579
if (!internal.ParseFromString(*parser.ColumnParser(INTERNAL_COLUMN_NAME).GetOptionalString())) {
580580
commonCounters->ParseProtobufError->Inc();
581-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "ERROR PARSING " QUERIES_TABLE_NAME "." INTERNAL_COLUMN_NAME " where " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\" and " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\"";
581+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "ERROR PARSING " QUERIES_TABLE_NAME "." INTERNAL_COLUMN_NAME " where " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\" and " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\"";
582582
}
583583
}
584584

585585
{
586586
TResultSetParser parser(resultSets[1]);
587587
if (!parser.TryNextRow()) {
588588
commonCounters->ParseProtobufError->Inc();
589-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "NOT FOUND " PENDING_SMALL_TABLE_NAME " where " TENANT_COLUMN_NAME " = \"" << request.tenant() << "\" and " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\" and " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\"" ;
589+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "NOT FOUND " PENDING_SMALL_TABLE_NAME " where " TENANT_COLUMN_NAME " = \"" << request.tenant() << "\" and " SCOPE_COLUMN_NAME " = \"" << request.scope() << "\" and " QUERY_ID_COLUMN_NAME " = \"" << request.query_id().value() << "\"" ;
590590
}
591591
owner = *parser.ColumnParser(OWNER_COLUMN_NAME).GetOptionalString();
592592
if (owner != request.owner_id()) {
593-
ythrow TCodeLineException(TIssuesIds::BAD_REQUEST) << "OWNER of QUERY ID = \"" << request.query_id().value() << "\" MISMATCHED: \"" << request.owner_id() << "\" (received) != \"" << owner << "\" (selected)";
593+
ythrow NYql::TCodeLineException(TIssuesIds::BAD_REQUEST) << "OWNER of QUERY ID = \"" << request.query_id().value() << "\" MISMATCHED: \"" << request.owner_id() << "\" (received) != \"" << owner << "\" (selected)";
594594
}
595595
}
596596

‎ydb/core/fq/libs/control_plane_storage/internal/task_result_write.cpp‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ void TYdbControlPlaneStorageActor::Handle(TEvControlPlaneStorage::TEvWriteResult
3939
for (const auto& row : resultSet.rows()) {
4040
TString serializedRow;
4141
if (!row.SerializeToString(&serializedRow)) {
42-
ythrow TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "Error serialize proto message for row. Please contact internal support";
42+
ythrow NYql::TCodeLineException(TIssuesIds::INTERNAL_ERROR) << "Error serialize proto message for row. Please contact internal support";
4343
}
4444

4545
itemsAsList.AddListItem()

‎ydb/core/fq/libs/control_plane_storage/internal/utils.h‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88

99
#include <ydb/core/fq/libs/config/protos/issue_id.pb.h>
1010
#include <ydb/core/fq/libs/control_plane_storage/ydb_control_plane_storage_impl.h>
11-
#include <ydb/core/fq/libs/exceptions/exceptions.h>
11+
#include <ydb/library/yql/utils/exceptions.h>
1212

1313
namespace NFq {
1414

‎ydb/core/fq/libs/control_plane_storage/internal/ya.make‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ PEERDIR(
2121
ydb/core/fq/libs/compute/common
2222
ydb/core/fq/libs/config
2323
ydb/core/fq/libs/control_plane_storage/proto
24-
ydb/core/fq/libs/exceptions
2524
ydb/core/fq/libs/metrics
2625
ydb/core/fq/libs/quota_manager
2726
ydb/core/fq/libs/quota_manager/events
@@ -31,6 +30,7 @@ PEERDIR(
3130
ydb/library/protobuf_printer
3231
ydb/library/security
3332
ydb/library/yql/public/issue
33+
ydb/library/yql/utils
3434
ydb/public/lib/fq
3535
ydb/public/sdk/cpp/client/ydb_scheme
3636
ydb/public/sdk/cpp/client/ydb_value

0 commit comments

Comments
 (0)