File tree 1 file changed +15
-2
lines changed
ydb/core/kqp/workload_service/actors
1 file changed +15
-2
lines changed Original file line number Diff line number Diff line change @@ -264,6 +264,11 @@ class TPoolCreatorActor : public TSchemeActorBase<TPoolCreatorActor> {
264
264
265
265
void Handle (TEvTxUserProxy::TEvProposeTransactionStatus::TPtr& ev) {
266
266
const auto & response = ev->Get ()->Record ;
267
+ if (IsUnsupportedIssue (response)) {
268
+ Reply (Ydb::StatusIds::UNSUPPORTED, ExtractIssues (response));
269
+ return ;
270
+ }
271
+
267
272
const auto ssStatus = response.GetSchemeShardStatus ();
268
273
const auto status = ev->Get ()->Status ();
269
274
switch (status) {
@@ -433,10 +438,18 @@ class TPoolCreatorActor : public TSchemeActorBase<TPoolCreatorActor> {
433
438
PassAway ();
434
439
}
435
440
436
- static NYql::TIssues ExtractIssues (const NKikimrTxUserProxy::TEvProposeTransactionStatus& response, const TString& message ) {
441
+ static NYql::TIssues ExtractIssues (const NKikimrTxUserProxy::TEvProposeTransactionStatus& response) {
437
442
NYql::TIssues issues;
438
443
NYql::IssuesFromMessage (response.GetIssues (), issues);
439
- return GroupIssues (issues, message);
444
+ return issues;
445
+ }
446
+
447
+ static NYql::TIssues ExtractIssues (const NKikimrTxUserProxy::TEvProposeTransactionStatus& response, const TString& message) {
448
+ return GroupIssues (ExtractIssues (response), message);
449
+ }
450
+
451
+ static bool IsUnsupportedIssue (const NKikimrTxUserProxy::TEvProposeTransactionStatus& response) {
452
+ return ExtractIssues (response).ToOneLineString ().Contains (" Resource pools are disabled" );
440
453
}
441
454
442
455
private:
You can’t perform that action at this time.
0 commit comments