aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorazevaykin <145343289+azevaykin@users.noreply.github.com>2025-05-30 09:07:01 +0300
committerGitHub <noreply@github.com>2025-05-30 06:07:01 +0000
commiteb99c58c8538add7728f37ceffefd81dc512619d (patch)
treee0843c288fbb2ead12a9703e1f064cbfa50e1eaf
parent9b7ace6b547ba2a8551fa6fb5b57c54b19bde68f (diff)
downloadydb-eb99c58c8538add7728f37ceffefd81dc512619d.tar.gz
Rolling update test for followers statistics (#18876)
-rw-r--r--ydb/tests/compatibility/test_statistics.py18
1 files changed, 7 insertions, 11 deletions
diff --git a/ydb/tests/compatibility/test_statistics.py b/ydb/tests/compatibility/test_statistics.py
index c2d4e4aad48..1ee7647d345 100644
--- a/ydb/tests/compatibility/test_statistics.py
+++ b/ydb/tests/compatibility/test_statistics.py
@@ -2,7 +2,7 @@
import pytest
import random
import threading
-from ydb.tests.library.compatibility.fixtures import RestartToAnotherVersionFixture
+from ydb.tests.library.compatibility.fixtures import RestartToAnotherVersionFixture, RollingUpgradeAndDowngradeFixture
from ydb.tests.oss.ydb_sdk_import import ydb
TABLE_NAME = "table"
@@ -121,7 +121,7 @@ class TestStatisticsTLI(RestartToAnotherVersionFixture):
self.check_partition_stats()
-class TestStatisticsFollowers(RestartToAnotherVersionFixture):
+class TestStatisticsFollowersRollingUpdate(RollingUpgradeAndDowngradeFixture):
@pytest.fixture(autouse=True, scope="function")
def setup(self):
@@ -166,18 +166,14 @@ class TestStatisticsFollowers(RestartToAnotherVersionFixture):
WITH (
AUTO_PARTITIONING_BY_SIZE = ENABLED,
AUTO_PARTITIONING_PARTITION_SIZE_MB = 1,
- READ_REPLICAS_SETTINGS = "PER_AZ:1"
+ READ_REPLICAS_SETTINGS = "ANY_AZ:1"
);
"""
session_pool.execute_with_retries(query)
- def test_statistics_followers(self):
+ def test_example(self):
self.create_table()
- self.write_data()
- self.check_statistics()
-
- self.change_cluster_version()
-
- self.write_data()
- self.check_statistics()
+ for _ in self.roll():
+ self.write_data()
+ self.check_statistics()