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 <berenguerbl...@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-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
