Skip to content

Commit

Permalink
Fix test failures due to cep-37
Browse files Browse the repository at this point in the history
  • Loading branch information
@jaydeep1984
jaydeep1984 committed Oct 7, 2024
1 parent e19d27e commit 0865e33
Showing 1 changed file with 24 additions and 8 deletions.
32 changes: 24 additions & 8 deletions cqlsh_tests/test_cqlsh.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1201,7 +1201,9 @@ 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 automated_repair_full = {'enabled': 'true'}
AND automated_repair_incremental = {'enabled': 'true'};
""" % self.get_compaction()
elif self.cluster.version() >= LooseVersion('4.1'):
create_table += """
Expand All @@ -1222,7 +1224,9 @@ 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 automated_repair_full = {'enabled': 'true'}
AND automated_repair_incremental = {'enabled': 'true'};
"""
elif self.cluster.version() >= LooseVersion('4.0'):
create_table += """
Expand Down Expand Up @@ -1334,7 +1338,9 @@ 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 automated_repair_full = {'enabled': 'true'}
AND automated_repair_incremental = {'enabled': 'true'};
""" % self.get_compaction()
elif self.cluster.version() >= LooseVersion('4.1'):
create_table = """
Expand All @@ -1359,7 +1365,9 @@ 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 automated_repair_full = {'enabled': 'true'}
AND automated_repair_incremental = {'enabled': 'true'};
"""
elif self.cluster.version() >= LooseVersion('4.0'):
create_table = """
Expand All @@ -1383,7 +1391,9 @@ 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 automated_repair_full = {'enabled': 'true'}
AND automated_repair_incremental = {'enabled': 'true'};
"""
elif self.cluster.version() >= LooseVersion('3.9'):
create_table = """
Expand All @@ -1405,7 +1415,9 @@ 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 automated_repair_full = {'enabled': 'true'}
AND automated_repair_incremental = {'enabled': 'true'};
"""
elif self.cluster.version() >= LooseVersion('3.0'):
create_table = """
Expand Down Expand Up @@ -1497,7 +1509,9 @@ 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 automated_repair_full = {'enabled': 'true'}
AND automated_repair_incremental = {'enabled': 'true'};
""" % self.get_compaction()
elif self.cluster.version() >= LooseVersion('4.1'):
return """
Expand All @@ -1522,7 +1536,9 @@ 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 automated_repair_full = {'enabled': 'true'}
AND automated_repair_incremental = {'enabled': 'true'};
"""
elif self.cluster.version() >= LooseVersion('4.0'):
return """
Expand Down

0 comments on commit 0865e33

Please sign in to comment.