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

Prevented hang in test_speculative_and_timeout

Browse Source
This commit is contained in:
bjmb 2017-05-18 19:02:29 -04:00
parent 88b1da1d6e
commit d3664dd00a
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/integration/standard/test_policies.py
View File

@ -133,7 +133,8 @@ class SpecExecTest(BasicSharedKeyspaceUnitTestCase):
# that's why we can't call session.execute,which would raise it, but
# we have to directly wait for the event
response_future = self.session.execute_async(statement, execution_profile='spec_ep_brr_lim', timeout=2.2)
response_future._event.wait()
response_future._event.wait(4)
self.assertIsInstance(response_future._final_exception, OperationTimedOut)
# This is because 2.2 / 0.4 + 1 = 6
self.assertEqual(len(response_future.attempted_hosts), 6)