[ymq] waiting for queue cache invalidation in test

init

1 files changed, 5 insertions, 0 deletions

diff --git a/ydb/tests/functional/sqs/multinode/test_recompiles_requests.py b/ydb/tests/functional/sqs/multinode/test_recompiles_requests.py
index fe7eada7419..deb88462099 100644
--- a/ydb/tests/functional/sqs/multinode/test_recompiles_requests.py
+++ b/ydb/tests/functional/sqs/multinode/test_recompiles_requests.py
@@ -1,6 +1,7 @@
 #!/usr/bin/env python
 # -*- coding: utf-8 -*-
 import pytest
+import time
 from hamcrest import assert_that, not_none
 
 from ydb.tests.library.common.types import Erasure
@@ -15,6 +16,7 @@ class TestSqsRecompilesRequestsForOtherQueue(KikimrSqsTestBase):
     def _setup_config_generator(cls):
         config_generator = super(TestSqsRecompilesRequestsForOtherQueue, cls)._setup_config_generator()
         config_generator.yaml_config['sqs_config']['enable_queue_master'] = False
+        config_generator.yaml_config['sqs_config']['leaders_describer_update_time_ms'] = 1000
         return config_generator
 
     @pytest.mark.parametrize(**IS_FIFO_PARAMS)
@@ -45,5 +47,8 @@ class TestSqsRecompilesRequestsForOtherQueue(KikimrSqsTestBase):
         self._sqs_api.delete_queue(queue_url)
         self._create_queue_and_assert(self.queue_name, is_fifo=is_fifo)
 
+        # waiting for queue cache invalidation
+        time.sleep(self.config_generator.yaml_config['sqs_config']['leaders_describer_update_time_ms'] * 2 / 1000.0)
+
         # send through node 1
         send(1)