Fixed test_thread_safety in unit tests
This commit is contained in:
parent
84872aeecd
commit
816e1cae3a
@ -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