Skip to content

Commit c7cde4f

Browse files
author
A. Jesse Jiryu Davis
committed
Use gevent.sleep where appropriate in tests
1 parent 79077a0 commit c7cde4f

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

test/test_pooling_base.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -783,7 +783,7 @@ def _test_max_pool_size(
783783
t.join()
784784

785785
# join() returns before the thread state is cleared; give it time.
786-
time.sleep(1)
786+
self.sleep(1)
787787

788788
for t in threads:
789789
self.assertTrue(t.passed)
@@ -827,7 +827,7 @@ def _test_max_pool_size(
827827

828828
# thread.join completes slightly *before* thread locals are
829829
# cleaned up, so wait up to 5 seconds for them.
830-
time.sleep(0.1)
830+
self.sleep(0.1)
831831
cx_pool._ident.get()
832832
start = time.time()
833833

@@ -836,7 +836,7 @@ def _test_max_pool_size(
836836
and cx_pool._socket_semaphore.counter < max_pool_size
837837
and (time.time() - start) < 5
838838
):
839-
time.sleep(0.1)
839+
self.sleep(0.1)
840840
cx_pool._ident.get()
841841

842842
self.assertEqual(max_pool_size, cx_pool._socket_semaphore.counter)
@@ -904,7 +904,7 @@ def _test_max_pool_size_no_rendezvous(self, start_request, end_request):
904904

905905
# thread.join completes slightly *before* thread locals are
906906
# cleaned up, so wait up to 5 seconds for them.
907-
time.sleep(0.1)
907+
self.sleep(0.1)
908908
cx_pool._ident.get()
909909
start = time.time()
910910

@@ -913,7 +913,7 @@ def _test_max_pool_size_no_rendezvous(self, start_request, end_request):
913913
and cx_pool._socket_semaphore.counter < max_pool_size
914914
and (time.time() - start) < 5
915915
):
916-
time.sleep(0.1)
916+
self.sleep(0.1)
917917
cx_pool._ident.get()
918918

919919
self.assertTrue(len(cx_pool.sockets) >= 1)

0 commit comments

Comments
 (0)