openstack/deb-python-cassandra-driver
Code Issues Proposed changes

Commit pending changes to rebase

Browse Source
This commit is contained in:
Joaquin Casares
2013-12-06 17:29:02 -06:00
parent 8c51776bdf
commit d37b83bd0a
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
tests/integration/long/test_consistency.py
View File

@@ -32,14 +32,15 @@ class ConsistencyTests(unittest.TestCase):
create_schema(session, keyspace, replication_factor=1)
init(session, keyspace, 12)
reset_coordinators()
query(session, keyspace, 12)
assert_queried(1, 0)
assert_queried(2, 12)
assert_queried(3, 0)
try:
reset_coordinators()
force_stop(2)
wait_for_down(cluster, 2)
@@ -79,7 +80,7 @@ class ConsistencyTests(unittest.TestCase):
try:
init(session, keyspace, 12, consistency_level=cl)
self._cl_expected_failure(cl)
except cassandra.Unavailable as e:
except (cassandra.Unavailable, cassandra.WriteTimeout) as e:
if not cl in [ConsistencyLevel.ONE,
ConsistencyLevel.TWO,
ConsistencyLevel.QUORUM,
@@ -120,6 +121,7 @@ class ConsistencyTests(unittest.TestCase):
create_schema(session, keyspace, replication_factor=2)
init(session, keyspace, 12)
wait_for_up(cluster, 2)
reset_coordinators()
query(session, keyspace, 12)