Merge pull request #761 from datastax/update_unit_test
Fixed test_thread_safety in unit tests
This commit is contained in:
commit
e4ad5d5338
@ -105,7 +105,7 @@ class RoundRobinPolicyTest(unittest.TestCase):
|
|||||||
def check_query_plan():
|
def check_query_plan():
|
||||||
for i in range(100):
|
for i in range(100):
|
||||||
qplan = list(policy.make_query_plan())
|
qplan = list(policy.make_query_plan())
|
||||||
self.assertEqual(sorted(qplan), hosts)
|
self.assertEqual(sorted(qplan), list(hosts))
|
||||||
|
|
||||||
threads = [Thread(target=check_query_plan) for i in range(4)]
|
threads = [Thread(target=check_query_plan) for i in range(4)]
|
||||||
for t in threads:
|
for t in threads:
|
||||||
|
Loading…
Reference in New Issue
Block a user