summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2019-03-21 22:48:11 -0700
committerGitHub <noreply@github.com>2019-03-21 22:48:11 -0700
commitd032844ad945b6e99845c40cfe08e026a56d332a (patch)
tree342a490514947644d94b0a9ec1fc38ad9f92081c
parentd620703305667f6292075357b36cb98681dc627b (diff)
downloadkafka-python-d032844ad945b6e99845c40cfe08e026a56d332a.tar.gz
Fix flaky conn tests that use time.time (#1758)
-rw-r--r--test/test_conn.py21
1 files changed, 12 insertions, 9 deletions
diff --git a/test/test_conn.py b/test/test_conn.py
index 66b8a0c..5da5eff 100644
--- a/test/test_conn.py
+++ b/test/test_conn.py
@@ -74,18 +74,21 @@ def test_connect_timeout(_socket, conn):
def test_blacked_out(conn):
- assert conn.blacked_out() is False
- conn.last_attempt = time.time()
- assert conn.blacked_out() is True
+ with mock.patch("time.time", return_value=1000):
+ conn.last_attempt = 0
+ assert conn.blacked_out() is False
+ conn.last_attempt = 1000
+ assert conn.blacked_out() is True
def test_connection_delay(conn):
- conn.last_attempt = time.time()
- assert round(conn.connection_delay()) == round(conn.config['reconnect_backoff_ms'])
- conn.state = ConnectionStates.CONNECTING
- assert conn.connection_delay() == 0
- conn.state = ConnectionStates.CONNECTED
- assert conn.connection_delay() == float('inf')
+ with mock.patch("time.time", return_value=1000):
+ conn.last_attempt = 1000
+ assert conn.connection_delay() == conn.config['reconnect_backoff_ms']
+ conn.state = ConnectionStates.CONNECTING
+ assert conn.connection_delay() == 0
+ conn.state = ConnectionStates.CONNECTED
+ assert conn.connection_delay() == float('inf')
def test_connected(conn):