YMQ Verify fix (#3945)

Co-authored-by: Sergey Veselov <[email protected]>

Author: alexnick88

ydb/core/ymq/actor/action.h

@@ -649,6 +649,8 @@ class TActionActor
             }
         }
 
+        Y_ABORT_UNLESS(SchemeCache_);
+
         bool isACLProtectedAccount = Cfg().GetForceAccessControl();
         if (!IsCloud() && (SecurityToken_ || (Cfg().GetForceAccessControl() && (isACLProtectedAccount = IsACLProtectedAccount(UserName_))))) {
             this->Become(&TActionActor::WaitAuthCheckMessages);
@@ -666,8 +668,6 @@ class TActionActor
                 return;
             }
 
-            Y_ABORT_UNLESS(SchemeCache_);
-
             RequestSchemeCache(GetActionACLSourcePath()); // this also checks that requested queue (if any) does exist
             RequestTicketParser();
         } else {

ydb/core/ymq/actor/service.cpp

@@ -685,6 +685,7 @@ void TSqsService::AnswerThrottled(TSqsEvents::TEvGetConfiguration::TPtr& ev) {
     RLOG_SQS_REQ_DEBUG(ev->Get()->RequestId, "Throttled because of too many requests for nonexistent queue [" << ev->Get()->QueueName << "] for user [" << ev->Get()->UserName << "] while getting configuration");
     auto answer = MakeHolder<TSqsEvents::TEvConfiguration>();
     answer->Throttled = true;
+    answer->SchemeCache = SchemeCache_;
     Send(ev->Sender, answer.Release());
 }
 

ydb/tests/functional/sqs/common/test_throttling_nonexistent_queue.py

@@ -4,6 +4,8 @@
 
 from ydb.tests.library.sqs.test_base import KikimrSqsTestBase
 
+throttling_exception_pattern = ".*</Message><Code>ThrottlingException</Code>.*"
+
 
 class TestSqsThrottlingOnNonexistentQueue(KikimrSqsTestBase):
 
@@ -21,8 +23,6 @@ def get_attributes_of_nonexistent_queue():
             except Exception:
                 pass
 
-        throttling_exception_pattern = ".*</Message><Code>ThrottlingException</Code>.*"
-
         assert_that(
             get_attributes_of_nonexistent_queue,
             raises(
@@ -46,3 +46,25 @@ def get_attributes_of_nonexistent_queue():
                 pattern=throttling_exception_pattern
             )
         )
+
+    def test_action_which_does_not_requere_existing_queue(self):
+        queue_url = self._create_queue_and_assert(self.queue_name, False, True)
+        nonexistent_queue_url = queue_url + "_nonex"
+
+        def get_attributes_of_nonexistent_queue():
+            self._sqs_api.get_queue_attributes(nonexistent_queue_url)
+
+        # Draining budget
+        for _ in range(16):
+            try:
+                get_attributes_of_nonexistent_queue()
+            except Exception:
+                pass
+
+        assert_that(
+            lambda: self._sqs_api.get_queue_url(self.queue_name + "_nonex"),
+            raises(
+                RuntimeError,
+                pattern=throttling_exception_pattern
+            )
+        )