From 8225ecf0fa267cb1f33c209559b652595e49c0e6 Mon Sep 17 00:00:00 2001 From: Philip O'Toole Date: Thu, 18 Jan 2024 07:47:16 -0500 Subject: [PATCH] More wait-for-applied --- system_test/e2e/auto_clustering.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/system_test/e2e/auto_clustering.py b/system_test/e2e/auto_clustering.py index e031651e..5c4ee6e2 100644 --- a/system_test/e2e/auto_clustering.py +++ b/system_test/e2e/auto_clustering.py @@ -251,6 +251,7 @@ class TestAutoClusteringKVStores(unittest.TestCase): n3 = Node(RQLITED_PATH, '3') n3.start(disco_mode=mode, disco_key=disco_key, join_interval='1s', join_attempts=1) n3.wait_for_leader() + n3.wait_for_all_applied() self.assertEqual(n3.disco_mode(), mode) j = n3.query('SELECT * FROM foo', level='none') self.assertEqual(j, d_("{'results': [{'values': [[1, 'fiona']], 'types': ['integer', 'text'], 'columns': ['id', 'name']}]}")) @@ -259,6 +260,7 @@ class TestAutoClusteringKVStores(unittest.TestCase): n4 = Node(RQLITED_PATH, '4', raft_voter=False) n4.start(disco_mode=mode, disco_key=disco_key, join_interval='1s', join_attempts=1) n4.wait_for_leader() + n4.wait_for_all_applied() self.assertEqual(n4.disco_mode(), mode) j = n4.query('SELECT * FROM foo', level='none') self.assertEqual(j, d_("{'results': [{'values': [[1, 'fiona']], 'types': ['integer', 'text'], 'columns': ['id', 'name']}]}"))