diff --git a/cqlsh_tests/test_cqlsh.py b/cqlsh_tests/test_cqlsh.py index 3619aa7619..70a462945e 100644 --- a/cqlsh_tests/test_cqlsh.py +++ b/cqlsh_tests/test_cqlsh.py @@ -1201,7 +1201,8 @@ def get_test_table_output(self, has_val=True, has_val_idx=True): AND memtable_flush_period_in_ms = 0 AND min_index_interval = 128 AND read_repair = 'BLOCKING' - AND speculative_retry = '99p'; + AND speculative_retry = '99p' + AND auto_repair = {'full_enabled': 'true', 'incremental_enabled': 'true', 'preview_repaired_enabled': 'true', 'priority': '0'}; """ % self.get_compaction() elif self.cluster.version() >= LooseVersion('4.1'): create_table += """ @@ -1222,7 +1223,8 @@ def get_test_table_output(self, has_val=True, has_val_idx=True): AND memtable_flush_period_in_ms = 0 AND min_index_interval = 128 AND read_repair = 'BLOCKING' - AND speculative_retry = '99p'; + AND speculative_retry = '99p' + AND auto_repair = {'full_enabled': 'true', 'incremental_enabled': 'true', 'preview_repaired_enabled': 'true', 'priority': '0'}; """ elif self.cluster.version() >= LooseVersion('4.0'): create_table += """ @@ -1334,7 +1336,8 @@ def get_users_table_output(self): AND memtable_flush_period_in_ms = 0 AND min_index_interval = 128 AND read_repair = 'BLOCKING' - AND speculative_retry = '99p'; + AND speculative_retry = '99p' + AND auto_repair = {'full_enabled': 'true', 'incremental_enabled': 'true', 'preview_repaired_enabled': 'true', 'priority': '0'}; """ % self.get_compaction() elif self.cluster.version() >= LooseVersion('4.1'): create_table = """ @@ -1359,7 +1362,8 @@ def get_users_table_output(self): AND memtable_flush_period_in_ms = 0 AND min_index_interval = 128 AND read_repair = 'BLOCKING' - AND speculative_retry = '99p'; + AND speculative_retry = '99p' + AND auto_repair = {'full_enabled': 'true', 'incremental_enabled': 'true', 'preview_repaired_enabled': 'true', 'priority': '0'}; """ elif self.cluster.version() >= LooseVersion('4.0'): create_table = """ @@ -1383,7 +1387,8 @@ def get_users_table_output(self): AND memtable_flush_period_in_ms = 0 AND min_index_interval = 128 AND read_repair = 'BLOCKING' - AND speculative_retry = '99p'; + AND speculative_retry = '99p' + AND auto_repair = {'full_enabled': 'true', 'incremental_enabled': 'true', 'preview_repaired_enabled': 'true', 'priority': '0'}; """ elif self.cluster.version() >= LooseVersion('3.9'): create_table = """ @@ -1405,7 +1410,8 @@ def get_users_table_output(self): AND memtable_flush_period_in_ms = 0 AND min_index_interval = 128 AND read_repair_chance = 0.0 - AND speculative_retry = '99PERCENTILE'; + AND speculative_retry = '99p' + AND auto_repair = {'full_enabled': 'true', 'incremental_enabled': 'true', 'preview_repaired_enabled': 'true', 'priority': '0'}; """ elif self.cluster.version() >= LooseVersion('3.0'): create_table = """ @@ -1497,7 +1503,8 @@ def get_users_by_state_mv_output(self): AND memtable_flush_period_in_ms = 0 AND min_index_interval = 128 AND read_repair = 'BLOCKING' - AND speculative_retry = '99p'; + AND speculative_retry = '99p' + AND auto_repair = {'full_enabled': 'true', 'incremental_enabled': 'true', 'preview_repaired_enabled': 'true', 'priority': '0'}; """ % self.get_compaction() elif self.cluster.version() >= LooseVersion('4.1'): return """ @@ -1522,7 +1529,8 @@ def get_users_by_state_mv_output(self): AND memtable_flush_period_in_ms = 0 AND min_index_interval = 128 AND read_repair = 'BLOCKING' - AND speculative_retry = '99p'; + AND speculative_retry = '99p' + AND auto_repair = {'full_enabled': 'true', 'incremental_enabled': 'true', 'preview_repaired_enabled': 'true', 'priority': '0'}; """ elif self.cluster.version() >= LooseVersion('4.0'): return """