summaryrefslogtreecommitdiff
path: root/test/test_conn.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2018-03-08 08:17:36 -0800
committerGitHub <noreply@github.com>2018-03-08 08:17:36 -0800
commitb33a65116ef6936183f09ca56930ccae39378c5f (patch)
tree8127f25572c061574d733db7d1a1c21934a33a23 /test/test_conn.py
parent4c383daf8a9d7aaa5049a98d7d6da19c85793d2d (diff)
downloadkafka-python-b33a65116ef6936183f09ca56930ccae39378c5f.tar.gz
Fix BrokerConnection.connection_delay() to return milliseconds (#1414)
Diffstat (limited to 'test/test_conn.py')
-rw-r--r--test/test_conn.py9
1 files changed, 9 insertions, 0 deletions
diff --git a/test/test_conn.py b/test/test_conn.py
index 5698519..f35cebe 100644
--- a/test/test_conn.py
+++ b/test/test_conn.py
@@ -72,6 +72,15 @@ def test_blacked_out(conn):
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')
+
+
def test_connected(conn):
assert conn.connected() is False
conn.state = ConnectionStates.CONNECTED