You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ed...@apache.org on 2021/03/24 15:50:09 UTC
[cassandra-dtest] branch trunk updated: Fix flaky
test_ttl_deletions patch authored by Berenguer Blasi;
reviewed by Ekaterina Dimitrova and Andres de la Pena for CASSANDRA-16530
This is an automated email from the ASF dual-hosted git repository.
edimitrova pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-dtest.git
The following commit(s) were added to refs/heads/trunk by this push:
new 49f46fc Fix flaky test_ttl_deletions patch authored by Berenguer Blasi; reviewed by Ekaterina Dimitrova and Andres de la Pena for CASSANDRA-16530
49f46fc is described below
commit 49f46fce94c8f25f32e9b778ded8b14c30ad851e
Author: Bereng <be...@gmail.com>
AuthorDate: Mon Mar 22 11:42:46 2021 +0100
Fix flaky test_ttl_deletions
patch authored by Berenguer Blasi; reviewed by Ekaterina Dimitrova and Andres de la Pena for CASSANDRA-16530
---
paging_test.py | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
diff --git a/paging_test.py b/paging_test.py
index 2fdd53b..6983d3f 100644
--- a/paging_test.py
+++ b/paging_test.py
@@ -3189,7 +3189,7 @@ class TestPagingWithDeletions(BasePagingTester, PageAssertionMixin):
range(0, len(expected_data), page_size)]
pf = self.get_page_fetcher()
- pf.request_all()
+ pf.request_all(timeout=60)
assert pf.pagecount() == pagecount
assert pf.num_results_all() == num_page_results
@@ -3404,17 +3404,18 @@ class TestPagingWithDeletions(BasePagingTester, PageAssertionMixin):
data = self.setup_data()
# Set TTL to all row
+ ttl_seconds = 15
for row in data:
s = ("insert into paging_test (id, mytext, col1, col2, col3) "
- "values ({}, '{}', {}, {}, {}) using ttl 3;").format(
+ "values ({}, '{}', {}, {}, {}) using ttl {};").format(
row['id'], row['mytext'], row['col1'],
- row['col2'], row['col3'])
+ row['col2'], row['col3'], ttl_seconds)
self.session.execute(
SimpleStatement(s, consistency_level=CL.ALL)
)
self.check_all_paging_results(data, 8,
[25, 25, 25, 25, 25, 25, 25, 25])
- time.sleep(5)
+ time.sleep(ttl_seconds)
self.check_all_paging_results([], 0, [])
def test_failure_threshold_deletions(self):
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org