You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by be...@apache.org on 2022/07/14 05:11:23 UTC
[cassandra-dtest] branch trunk updated: Flaky dtest-upgrade.upgrade_tests.compatibility_flag_test.TestCompatibilityFlag.test__compatibility_flag_on_3014
This is an automated email from the ASF dual-hosted git repository.
bereng 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 1c257293 Flaky dtest-upgrade.upgrade_tests.compatibility_flag_test.TestCompatibilityFlag.test__compatibility_flag_on_3014
1c257293 is described below
commit 1c257293ba64e517b94240218bb64b80e9b52b2b
Author: Bereng <be...@gmail.com>
AuthorDate: Tue Jul 12 09:42:03 2022 +0200
Flaky dtest-upgrade.upgrade_tests.compatibility_flag_test.TestCompatibilityFlag.test__compatibility_flag_on_3014
Patch by Berenguer Blasi; reviewed by Brandon Williams for CASSANDRA-17747
---
upgrade_tests/compatibility_flag_test.py | 12 +++++++++---
1 file changed, 9 insertions(+), 3 deletions(-)
diff --git a/upgrade_tests/compatibility_flag_test.py b/upgrade_tests/compatibility_flag_test.py
index f778cea4..0bbc3da1 100644
--- a/upgrade_tests/compatibility_flag_test.py
+++ b/upgrade_tests/compatibility_flag_test.py
@@ -1,6 +1,8 @@
import pytest
import logging
+from cassandra import ConsistencyLevel
+from cassandra.query import SimpleStatement
from dtest import Tester
from tools.assertions import assert_all
@@ -93,17 +95,21 @@ class TestCompatibilityFlag(Tester):
session.execute("CREATE KEYSPACE test WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '2'} ;")
session.execute("CREATE TABLE test.test (a text PRIMARY KEY, b text, c text);")
+ session.cluster.control_connection.wait_for_schema_agreement()
for i in range(1, 6):
- session.execute("INSERT INTO test.test (a, b, c) VALUES ('{}', '{}', '{}');".format(i, i + 1, i + 2))
+ session.execute(SimpleStatement("INSERT INTO test.test (a, b, c) VALUES ('{}', '{}', '{}');".format(i, i + 1, i + 2),
+ consistency_level=ConsistencyLevel.ALL))
assert_all(session,
"SELECT * FROM test.test",
- [[str(i), str(i + 1), str(i + 2)] for i in range(1, 6)], ignore_order=True)
+ [[str(i), str(i + 1), str(i + 2)] for i in range(1, 6)], ignore_order=True,
+ cl=ConsistencyLevel.ALL)
assert_all(session,
"SELECT a,c FROM test.test",
- [[str(i), str(i + 2)] for i in range(1, 6)], ignore_order=True)
+ [[str(i), str(i + 2)] for i in range(1, 6)], ignore_order=True,
+ cl=ConsistencyLevel.ALL)
@since('3.0.14', max_version='3.0.x')
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org